class documentation

Undocumented

Method __init__ Undocumented
Async Method drain_poll_queue Undocumented
Method nondeterminism_as_workflow_fail Undocumented
Method nondeterminism_as_workflow_fail_for_types Undocumented
Method notify_shutdown Undocumented
Async Method run Undocumented
Method _create_workflow_instance Undocumented
Async Method _handle_activation Undocumented
Instance Variable _bridge_worker Undocumented
Instance Variable _could_not_evict_count Undocumented
Instance Variable _data_converter Undocumented
Instance Variable _deadlock_timeout_seconds Undocumented
Instance Variable _disable_eager_activity_execution Undocumented
Instance Variable _disable_safe_eviction Undocumented
Instance Variable _dynamic_workflow Undocumented
Instance Variable _extern_functions Undocumented
Instance Variable _interceptor_classes Undocumented
Instance Variable _namespace Undocumented
Instance Variable _on_eviction_hook Undocumented
Instance Variable _running_workflows Undocumented
Instance Variable _task_queue Undocumented
Instance Variable _throw_after_activation Undocumented
Instance Variable _unsandboxed_workflow_runner Undocumented
Instance Variable _workflow_failure_exception_types Undocumented
Instance Variable _workflow_runner Undocumented
Instance Variable _workflow_task_executor Undocumented
Instance Variable _workflow_task_executor_user_provided Undocumented
Instance Variable _workflows Undocumented
def __init__(self, *, bridge_worker: Callable[[], temporalio.bridge.worker.Worker], namespace: str, task_queue: str, workflows: Sequence[Type], workflow_task_executor: Optional[concurrent.futures.ThreadPoolExecutor], workflow_runner: WorkflowRunner, unsandboxed_workflow_runner: WorkflowRunner, data_converter: temporalio.converter.DataConverter, interceptors: Sequence[Interceptor], workflow_failure_exception_types: Sequence[Type[BaseException]], debug_mode: bool, disable_eager_activity_execution: bool, metric_meter: temporalio.common.MetricMeter, on_eviction_hook: Optional[Callable[[str, temporalio.bridge.proto.workflow_activation.RemoveFromCache], None]], disable_safe_eviction: bool): (source)

Undocumented

async def drain_poll_queue(self): (source)

Undocumented

def nondeterminism_as_workflow_fail(self) -> bool: (source)

Undocumented

def nondeterminism_as_workflow_fail_for_types(self) -> Set[str]: (source)

Undocumented

def notify_shutdown(self): (source)

Undocumented

async def run(self): (source)

Undocumented

Undocumented

_bridge_worker = (source)

Undocumented

_could_not_evict_count: int = (source)

Undocumented

_data_converter = (source)

Undocumented

_deadlock_timeout_seconds = (source)

Undocumented

_disable_eager_activity_execution = (source)

Undocumented

_disable_safe_eviction = (source)

Undocumented

Undocumented

_interceptor_classes: List[Type[WorkflowInboundInterceptor]] = (source)

Undocumented

_namespace = (source)

Undocumented

_on_eviction_hook = (source)

Undocumented

_running_workflows: Dict[str, WorkflowInstance] = (source)

Undocumented

_task_queue = (source)

Undocumented

_throw_after_activation: Optional[Exception] = (source)

Undocumented

_unsandboxed_workflow_runner = (source)

Undocumented

_workflow_failure_exception_types = (source)

Undocumented

_workflow_runner = (source)

Undocumented

_workflow_task_executor = (source)

Undocumented

_workflow_task_executor_user_provided = (source)

Undocumented