temporalio.contrib.opentelemetry._TracingActivityInboundInterceptor

class documentation

class _TracingActivityInboundInterceptor(temporalio.worker.ActivityInboundInterceptor): (source)

Constructor: _TracingActivityInboundInterceptor(next, root)

View In Hierarchy

Undocumented

Method __init__ Create the inbound interceptor.
Async Method execute_activity Called to invoke the activity.
Instance Variable root Undocumented

Inherited from ActivityInboundInterceptor:

Method init Initialize with an outbound interceptor.
Instance Variable next Undocumented
def __init__(self, next: temporalio.worker.ActivityInboundInterceptor, root: TracingInterceptor): (source)
overrides temporalio.worker.ActivityInboundInterceptor.__init__

Create the inbound interceptor.

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

Called to invoke the activity.

root = (source)

Undocumented