temporalio.activity.Info

class documentation

class Info: (source)

View In Hierarchy

Information about the running activity.

Retrieved inside an activity via info.

Class Variable activity_id Undocumented
Class Variable activity_type Undocumented
Class Variable attempt Undocumented
Class Variable current_attempt_scheduled_time Undocumented
Class Variable heartbeat_details Undocumented
Class Variable heartbeat_timeout Undocumented
Class Variable is_local Undocumented
Class Variable priority Undocumented
Class Variable retry_policy The retry policy of this activity.
Class Variable schedule_to_close_timeout Undocumented
Class Variable scheduled_time Undocumented
Class Variable start_to_close_timeout Undocumented
Class Variable started_time Undocumented
Class Variable task_queue Undocumented
Class Variable task_token Undocumented
Class Variable workflow_id Undocumented
Class Variable workflow_namespace Undocumented
Class Variable workflow_run_id Undocumented
Class Variable workflow_type Undocumented
Method _logger_details Undocumented
activity_id: str = (source)

Undocumented

activity_type: str = (source)

Undocumented

attempt: int = (source)

Undocumented

current_attempt_scheduled_time: datetime = (source)

Undocumented

heartbeat_details: Sequence[Any] = (source)

Undocumented

heartbeat_timeout: timedelta | None = (source)

Undocumented

is_local: bool = (source)

Undocumented

priority: temporalio.common.Priority = (source)

Undocumented

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

The retry policy of this activity.

Note that the server may have set a different policy than the one provided when scheduling the activity. If the value is None, it means the server didn't send information about retry policy (e.g. due to old server version), but it may still be defined server-side.

schedule_to_close_timeout: timedelta | None = (source)

Undocumented

scheduled_time: datetime = (source)

Undocumented

start_to_close_timeout: timedelta | None = (source)

Undocumented

started_time: datetime = (source)

Undocumented

task_queue: str = (source)

Undocumented

task_token: bytes = (source)

Undocumented

workflow_id: str = (source)

Undocumented

workflow_namespace: str = (source)

Undocumented

workflow_run_id: str = (source)

Undocumented

workflow_type: str = (source)

Undocumented

def _logger_details(self) -> Mapping[str, Any]: (source)

Undocumented