temporalio.client.ActivityExecutionDescription

temporalio.client.ActivityExecutionDescription

class documentation

class ActivityExecutionDescription(ActivityExecution): (source)

View In Hierarchy

Detailed information about an activity execution not started by a workflow.

Warning

This API is experimental.

Class Variable attempt Current attempt number.
Class Variable canceled_reason Reason for cancellation, if cancel was requested.
Class Variable current_retry_interval Time until the next retry, if applicable.
Class Variable eager_execution_requested Whether eager execution was requested for this activity.
Class Variable expiration_time Scheduled time plus schedule_to_close_timeout.
Class Variable last_attempt_complete_time Time when the last attempt completed.
Class Variable last_failure Failure from the last failed attempt, if any.
Class Variable last_heartbeat_time Time of the last heartbeat.
Class Variable last_started_time Time the last attempt was started.
Class Variable last_worker_identity Identity of the last worker that processed the activity.
Class Variable long_poll_token Token for follow-on long-poll requests. None if the activity is complete.
Class Variable next_attempt_schedule_time Time when the next attempt will be scheduled.
Class Variable paused Whether the activity is paused.
Class Variable raw_heartbeat_details Details from the last heartbeat.
Class Variable retry_policy Retry policy for the activity.
Class Variable run_state More detailed breakdown if status is RUNNING.
Async Class Method _from_execution_info Create from raw proto activity execution info.

Inherited from ActivityExecution:

attempt: int = (source)

Current attempt number.

canceled_reason: str | None = (source)

Reason for cancellation, if cancel was requested.

current_retry_interval: timedelta | None = (source)

Time until the next retry, if applicable.

eager_execution_requested: bool = (source)

Whether eager execution was requested for this activity.

expiration_time: datetime = (source)

Scheduled time plus schedule_to_close_timeout.

last_attempt_complete_time: datetime | None = (source)

Time when the last attempt completed.

last_failure: Exception | None = (source)

Failure from the last failed attempt, if any.

last_heartbeat_time: datetime | None = (source)

Time of the last heartbeat.

last_started_time: datetime | None = (source)

Time the last attempt was started.

last_worker_identity: str = (source)

Identity of the last worker that processed the activity.

long_poll_token: bytes | None = (source)

Token for follow-on long-poll requests. None if the activity is complete.

next_attempt_schedule_time: datetime | None = (source)

Time when the next attempt will be scheduled.

paused: bool = (source)

Whether the activity is paused.

raw_heartbeat_details: Sequence[temporalio.api.common.v1.Payload] = (source)

Details from the last heartbeat.

retry_policy: temporalio.common.RetryPolicy | None = (source)

Retry policy for the activity.

run_state: PendingActivityState | None = (source)

More detailed breakdown if status is RUNNING.

async def _from_execution_info(cls, info: temporalio.api.activity.v1.ActivityExecutionInfo, long_poll_token: bytes | None, namespace: str, data_converter: temporalio.converter.DataConverter) -> Self: (source)

Create from raw proto activity execution info.