temporalio.contrib.langsmith._interceptor._LangSmithClientOutboundInterceptor

class documentation

class _LangSmithClientOutboundInterceptor(temporalio.client.OutboundInterceptor): (source)

Constructor: _LangSmithClientOutboundInterceptor(next, config)

View In Hierarchy

Instruments all client-side calls with LangSmith runs.

Method __init__ Create the outbound interceptor.
Async Method query_workflow Called for every WorkflowHandle.query call.
Async Method signal_workflow Called for every WorkflowHandle.signal call.
Async Method start_update_with_start_workflow Called for every Client.start_update_with_start_workflow and Client.execute_update_with_start_workflow call.
Async Method start_workflow Called for every Client.start_workflow call.
Async Method start_workflow_update Called for every WorkflowHandle.start_update and WorkflowHandle.execute_update call.
Method _traced_call Wrap a client call with a LangSmith run and inject context into headers.
Method _traced_start Wrap a start operation, injecting ambient parent context before creating the run.
Instance Variable _config Undocumented

Inherited from OutboundInterceptor:

Async Method backfill_schedule Called for every ScheduleHandle.backfill call.
Async Method cancel_activity Called for every ActivityHandle.cancel call.
Async Method cancel_workflow Called for every WorkflowHandle.cancel call.
Async Method complete_async_activity Called for every AsyncActivityHandle.complete call.
Async Method count_activities Called for every Client.count_activities call.
Async Method count_workflows Called for every Client.count_workflows call.
Async Method create_schedule Called for every Client.create_schedule call.
Async Method delete_schedule Called for every ScheduleHandle.delete call.
Async Method describe_activity Called for every ActivityHandle.describe call.
Async Method describe_schedule Called for every ScheduleHandle.describe call.
Async Method describe_workflow Called for every WorkflowHandle.describe call.
Async Method fail_async_activity Called for every AsyncActivityHandle.fail call.
Method fetch_workflow_history_events Called for every WorkflowHandle.fetch_history_events call.
Async Method get_worker_build_id_compatibility Called for every Client.get_worker_build_id_compatibility call.
Async Method get_worker_task_reachability Called for every Client.get_worker_task_reachability call.
Async Method heartbeat_async_activity Called for every AsyncActivityHandle.heartbeat call.
Method list_activities Called for every Client.list_activities call.
Method list_schedules Called for every Client.list_schedules call.
Method list_workflows Called for every Client.list_workflows call.
Async Method pause_schedule Called for every ScheduleHandle.pause call.
Async Method report_cancellation_async_activity Called for every AsyncActivityHandle.report_cancellation call.
Async Method start_activity Called for every Client.start_activity call.
Async Method terminate_activity Called for every ActivityHandle.terminate call.
Async Method terminate_workflow Called for every WorkflowHandle.terminate call.
Async Method trigger_schedule Called for every ScheduleHandle.trigger call.
Async Method unpause_schedule Called for every ScheduleHandle.unpause call.
Async Method update_schedule Called for every ScheduleHandle.update call.
Async Method update_worker_build_id_compatibility Called for every Client.update_worker_build_id_compatibility call.
Instance Variable next Undocumented
def __init__(self, next: temporalio.client.OutboundInterceptor, config: LangSmithInterceptor): (source)
overrides temporalio.client.OutboundInterceptor.__init__

Create the outbound interceptor.

Parameters
next:temporalio.client.OutboundInterceptorThe next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor.
config:LangSmithInterceptorUndocumented
async def query_workflow(self, input: temporalio.client.QueryWorkflowInput) -> Any: (source)
overrides temporalio.client.OutboundInterceptor.query_workflow

Called for every WorkflowHandle.query call.

async def signal_workflow(self, input: temporalio.client.SignalWorkflowInput): (source)
overrides temporalio.client.OutboundInterceptor.signal_workflow

Called for every WorkflowHandle.signal call.

async def start_update_with_start_workflow(self, input: temporalio.client.StartWorkflowUpdateWithStartInput) -> temporalio.client.WorkflowUpdateHandle[Any]: (source)
overrides temporalio.client.OutboundInterceptor.start_update_with_start_workflow
async def start_workflow(self, input: temporalio.client.StartWorkflowInput) -> temporalio.client.WorkflowHandle[Any, Any]: (source)
overrides temporalio.client.OutboundInterceptor.start_workflow

Called for every Client.start_workflow call.

async def start_workflow_update(self, input: temporalio.client.StartWorkflowUpdateInput) -> temporalio.client.WorkflowUpdateHandle[Any]: (source)
overrides temporalio.client.OutboundInterceptor.start_workflow_update
def _traced_call(self, name: str, input: _InputWithHeaders) -> Iterator[None]: (source)

Wrap a client call with a LangSmith run and inject context into headers.

def _traced_start(self, name: str, input: _InputWithHeaders) -> Iterator[None]: (source)

Wrap a start operation, injecting ambient parent context before creating the run.

Unlike _traced_call, this injects headers before maybe_run so the downstream RunFoo becomes a sibling of StartFoo rather than a child.

_config = (source)

Undocumented