temporalio.contrib.langsmith._interceptor._LangSmithActivityInboundInterceptor

class documentation

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

Constructor: _LangSmithActivityInboundInterceptor(next, config)

View In Hierarchy

Instruments activity execution with LangSmith runs.

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

Inherited from ActivityInboundInterceptor:

Method init Initialize with an outbound interceptor.
Instance Variable next Undocumented
def __init__(self, next: temporalio.worker.ActivityInboundInterceptor, config: LangSmithInterceptor): (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.
config:LangSmithInterceptorUndocumented
async def execute_activity(self, input: temporalio.worker.ExecuteActivityInput) -> Any: (source)
overrides temporalio.worker.ActivityInboundInterceptor.execute_activity

Called to invoke the activity.

_config = (source)

Undocumented