temporalio.worker._activity._ActivityInboundImpl

class documentation

class _ActivityInboundImpl(ActivityInboundInterceptor): (source)

Constructor: _ActivityInboundImpl(worker, running_activity)

View In Hierarchy

Undocumented

Method __init__ Create the inbound interceptor.
Async Method execute_activity Called to invoke the activity.
Method init Initialize with an outbound interceptor.
Instance Variable _running_activity Undocumented
Instance Variable _worker Undocumented

Inherited from ActivityInboundInterceptor:

Instance Variable next Undocumented
def __init__(self, worker: _ActivityWorker, running_activity: _RunningActivity): (source)
overrides temporalio.worker.ActivityInboundInterceptor.__init__

Create the inbound interceptor.

Parameters
worker:_ActivityWorkerUndocumented
running_activity:_RunningActivityUndocumented
nextThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
async def execute_activity(self, input: ExecuteActivityInput) -> Any: (source)
overrides temporalio.worker.ActivityInboundInterceptor.execute_activity

Called to invoke the activity.

def init(self, outbound: ActivityOutboundInterceptor): (source)
overrides temporalio.worker.ActivityInboundInterceptor.init

Initialize with an outbound interceptor.

To add a custom outbound interceptor, wrap the given interceptor before sending to the next init call.

_running_activity = (source)

Undocumented

_worker = (source)

Undocumented