temporalio.worker._activity._ActivityOutboundImpl

class documentation

class _ActivityOutboundImpl(ActivityOutboundInterceptor): (source)

Constructor: _ActivityOutboundImpl(worker, info)

View In Hierarchy

Undocumented

Method __init__ Create the outbound interceptor.
Method heartbeat Called for every temporalio.activity.heartbeat call.
Method info Called for every temporalio.activity.info call.
Instance Variable _info Undocumented
Instance Variable _worker Undocumented

Inherited from ActivityOutboundInterceptor:

Instance Variable next Undocumented
def __init__(self, worker: _ActivityWorker, info: temporalio.activity.Info): (source)
overrides temporalio.worker.ActivityOutboundInterceptor.__init__

Create the outbound interceptor.

Parameters
worker:_ActivityWorkerUndocumented
info:temporalio.activity.InfoUndocumented
nextThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
def heartbeat(self, *details: Any): (source)
overrides temporalio.worker.ActivityOutboundInterceptor.heartbeat

Called for every temporalio.activity.heartbeat call.

def info(self) -> temporalio.activity.Info: (source)
overrides temporalio.worker.ActivityOutboundInterceptor.info

Called for every temporalio.activity.info call.

_info = (source)

Undocumented

_worker = (source)

Undocumented