temporalio.worker._activity._ActivityOutboundImpl

class documentation

class _ActivityOutboundImpl(ActivityOutboundInterceptor): (source)

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

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:`_ActivityWorker`	Undocumented
info:`temporalio.activity.Info`	Undocumented
next	The 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

def info(self) -> temporalio.activity.Info: (source) ¶

overrides temporalio.worker.ActivityOutboundInterceptor.info

Called for every temporalio.activity.info call.

Undocumented

Undocumented