temporalio.worker._nexus._ContextPropagatingExecutor

class documentation

class _ContextPropagatingExecutor(concurrent.futures.Executor): (source)

Constructor: _ContextPropagatingExecutor(executor)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method shutdown Undocumented
Method submit Undocumented
Instance Variable _executor Undocumented
def __init__(self, executor: concurrent.futures.ThreadPoolExecutor): (source)

Undocumented

def shutdown(self, wait: bool = True, *, cancel_futures: bool = False): (source)

Undocumented

def submit(self, fn: Callable[_P, _T], /, *args: _P.args, **kwargs: _P.kwargs) -> concurrent.futures.Future[_T]: (source)

Undocumented

_executor = (source)

Undocumented