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 _result_fut Undocumented
Instance Variable _seq Undocumented
Instance Variable _started Undocumented
def __init__(self, instance: _WorkflowInstanceImpl, input: Union[StartActivityInput, StartLocalActivityInput], fn: Coroutine[Any, Any, Any]): (source)

Undocumented

def cancel(self, msg: Optional[Any] = None) -> bool: (source)

Undocumented

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

Undocumented

def _apply_schedule_command(self, command: temporalio.bridge.proto.workflow_commands.WorkflowCommand, local_backoff: Optional[temporalio.bridge.proto.activity_result.DoBackoff] = 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

_result_fut = (source)

Undocumented

_seq = (source)

Undocumented

_started: bool = (source)

Undocumented