temporalio.worker._activity._RunningActivity

class documentation

class _RunningActivity: (source)

View In Hierarchy

Undocumented

Method cancel Undocumented
Class Variable cancel_thread_raiser Undocumented
Class Variable cancellation_details 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: Exception | None = None): (source)

Undocumented

cancel_thread_raiser: _ThreadExceptionRaiser | None = (source)

Undocumented

cancellation_details: temporalio.activity._ActivityCancellationDetailsHolder = (source)

Undocumented

cancelled_event: temporalio.activity._CompositeEvent | None = (source)

Undocumented

done: bool = (source)

Undocumented

info: temporalio.activity.Info | None = (source)

Undocumented

last_heartbeat_task: asyncio.Task | None = (source)

Undocumented

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

Undocumented

sync: bool = (source)

Undocumented

task: asyncio.Task | None = (source)

Undocumented

cancelled_by_request: bool = (source)

Undocumented

cancelled_due_to_heartbeat_error: Exception | None = (source)

Undocumented