temporalio.worker._workflow

module documentation
(source)

Workflow worker.

Constant LOG_PROTOS Undocumented
Variable logger Undocumented
Class _CommandAwareDataConverter Data converter that resolves serialization context per-command.
Class _RunningWorkflow Undocumented
Class _WorkflowWorker Undocumented
Exception _DeadlockError Exception class for deadlocks. Contains functionality to swap the default traceback for another.
Exception _InterruptDeadlockError Undocumented
Function _set_external_storage_metrics Populate a proto ExternalStorageMetrics from measured storage metrics.
Constant _DEFAULT_WORKFLOW_TASK_EXTERNAL_STORAGE_CONCURRENCY Undocumented
LOG_PROTOS: bool = (source)

Undocumented

Value
False
logger = (source)

Undocumented

def _set_external_storage_metrics(target: temporalio.bridge.proto.common.ExternalStorageMetrics, metrics: temporalio.converter._extstore.StorageOperationMetrics): (source)

Populate a proto ExternalStorageMetrics from measured storage metrics.

_DEFAULT_WORKFLOW_TASK_EXTERNAL_STORAGE_CONCURRENCY: int = (source)

Undocumented

Value
3