temporalio.worker._workflow_instance._ActivityHandle

class documentation

class _ActivityHandle(temporalio.workflow.ActivityHandle[Any]): (source)

Constructor: _ActivityHandle(instance, input, fn)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method cancel Undocumented
Method _apply_cancel_command Undocumented
Method _apply_schedule_command Undocumented
Method _resolve_backoff Undocumented
Method _resolve_failure Undocumented
Method _resolve_success Undocumented
Instance Variable _input Undocumented
Instance Variable _instance Undocumented
Instance Variable _payload_converter Undocumented
Instance Variable _result_fut Undocumented
Instance Variable _seq Undocumented
Instance Variable _started Undocumented
def __init__(self, instance: _WorkflowInstanceImpl, input: StartActivityInput | StartLocalActivityInput, fn: Coroutine[Any, Any, Any]): (source)

Undocumented

def cancel(self, msg: Any | None = None) -> bool: (source)

Undocumented

def _apply_cancel_command(self, command: temporalio.bridge.proto.workflow_commands.WorkflowCommand): (source)

Undocumented

def _apply_schedule_command(self, local_backoff: temporalio.bridge.proto.activity_result.DoBackoff | None = None): (source)

Undocumented

def _resolve_backoff(self, backoff: temporalio.bridge.proto.activity_result.DoBackoff): (source)

Undocumented

def _resolve_failure(self, err: BaseException): (source)

Undocumented

def _resolve_success(self, result: Any): (source)

Undocumented

_input = (source)

Undocumented

_instance = (source)

Undocumented

_payload_converter = (source)

Undocumented

_result_fut = (source)

Undocumented

_seq = (source)

Undocumented

_started: bool = (source)

Undocumented