class documentation
class _LangSmithNexusOperationInboundInterceptor(temporalio.worker.NexusOperationInboundInterceptor): (source)
Constructor: _LangSmithNexusOperationInboundInterceptor(next, config)
Instruments Nexus operations with LangSmith runs.
| Method | __init__ |
Create the inbound interceptor. |
| Async Method | execute |
Called to cancel an in progress Nexus operation |
| Async Method | execute |
Called to start a Nexus operation |
| Instance Variable | _config |
Undocumented |
Inherited from NexusOperationInboundInterceptor:
| Instance Variable | next |
Undocumented |
def __init__(self, next:
temporalio.worker.NexusOperationInboundInterceptor, config: LangSmithInterceptor):
(source)
¶
Create the inbound interceptor.
| Parameters | |
next:temporalio.worker.NexusOperationInboundInterceptor | The next interceptor in the chain. The default implementation of all calls is to delegate to the next interceptor. |
config:LangSmithInterceptor | Undocumented |
async def execute_nexus_operation_cancel(self, input:
temporalio.worker.ExecuteNexusOperationCancelInput):
(source)
¶
Called to cancel an in progress Nexus operation
async def execute_nexus_operation_start(self, input:
temporalio.worker.ExecuteNexusOperationStartInput) -> nexusrpc.handler.StartOperationResultSync[:
(source)
¶
Called to start a Nexus operation