temporalio.worker._activity._RunningActivity

class documentation

class _RunningActivity: (source)

View In Hierarchy

Undocumented

Method cancel Undocumented
Class Variable cancel_thread_raiser Undocumented
Class Variable cancelled_event Undocumented
Class Variable done Undocumented
Class Variable info Undocumented
Class Variable last_heartbeat_task Undocumented
Class Variable pending_heartbeats Undocumented
Class Variable sync Undocumented
Class Variable task Undocumented
Instance Variable cancelled_by_request Undocumented
Instance Variable cancelled_due_to_heartbeat_error Undocumented
def cancel(self, *, cancelled_by_request: bool = False, cancelled_due_to_heartbeat_error: Optional[Exception] = None): (source)

Undocumented

cancel_thread_raiser: Optional[_ThreadExceptionRaiser] = (source)

Undocumented

cancelled_event: Optional[temporalio.activity._CompositeEvent] = (source)

Undocumented

done: bool = (source)

Undocumented

info: Optional[temporalio.activity.Info] = (source)

Undocumented

last_heartbeat_task: Optional[asyncio.Task] = (source)

Undocumented

pending_heartbeats: asyncio.Queue[Sequence[Any]] = (source)

Undocumented

sync: bool = (source)

Undocumented

task: Optional[asyncio.Task] = (source)

Undocumented

cancelled_by_request = (source)

Undocumented

cancelled_due_to_heartbeat_error = (source)

Undocumented