module documentation
Activity worker.
Variable | logger |
Undocumented |
Class | _ |
Undocumented |
Class | _ |
Undocumented |
Class | _ |
Undocumented |
Class | _ |
Undocumented |
Class | _ |
Undocumented |
Class | _ |
Undocumented |
Class | _ |
Undocumented |
Function | _execute |
Undocumented |
Function | _proto |
Undocumented |
Function | _proto |
Undocumented |
Variable | _multiprocess |
Undocumented |
def _execute_sync_activity(info:
temporalio.activity.Info
, heartbeat: Union[ Callable[ ..., None], SharedHeartbeatSender]
, cancel_thread_raiser: Optional[ _ThreadExceptionRaiser]
, cancelled_event: threading.Event
, worker_shutdown_event: threading.Event
, fn: Callable[ ..., Any]
, *args: Any
) -> Any
:
(source)
¶
Undocumented
def _proto_to_non_zero_timedelta(dur:
google.protobuf.duration_pb2.Duration
) -> Optional[ timedelta]
:
(source)
¶
Undocumented