temporalio.worker._worker

module documentation
(source)

Worker for processing Temporal workflows and/or activities.

Function load_default_build_id Load the default worker build ID.
Variable logger Undocumented
Exception _ShutdownRequested Undocumented
Function _extract_bridge_client_for_worker Undocumented
Function _get_module_code Undocumented
Function _warn_if_activity_executor_max_workers_is_inconsistent Undocumented
Function _warn_if_nexus_task_executor_max_workers_is_inconsistent Undocumented
Variable _default_build_id Undocumented
def load_default_build_id(*, memoize: bool = True) -> str: (source)

Load the default worker build ID.

The worker build ID is a unique hash representing the entire set of code including Temporal code and external code. The default here is currently implemented by walking loaded modules and hashing their bytecode into a common hash.

Parameters
memoize:boolIf true, the default, this will cache to a global variable to keep from having to run again on successive calls.
Returns
strUnique identifier representing the set of running code.
logger = (source)

Undocumented

def _extract_bridge_client_for_worker(client: temporalio.client.Client) -> temporalio.service._BridgeServiceClient: (source)

Undocumented

def _get_module_code(mod_name: str) -> bytes | None: (source)

Undocumented

def _warn_if_activity_executor_max_workers_is_inconsistent(config: WorkerConfig): (source)

Undocumented

def _warn_if_nexus_task_executor_max_workers_is_inconsistent(config: WorkerConfig): (source)

Undocumented

_default_build_id: str | None = (source)

Undocumented