temporalio.worker._activity._ThreadExceptionRaiser

temporalio.worker._activity._ThreadExceptionRaiser

class documentation

class _ThreadExceptionRaiser: (source)

View In Hierarchy

Undocumented

def __init__(self): (source)

Undocumented

def active_thread(self) -> Iterator[None]: (source)

Undocumented

def raise_in_thread(self, exc_type: type[Exception]): (source)

Undocumented

def set_thread_id(self, thread_id: int): (source)

Undocumented

def shielded(self) -> Iterator[None]: (source)

Undocumented

def _raise_in_thread_if_pending_unlocked(self): (source)

Undocumented

_lock = (source)

Undocumented

_pending_exception: type[Exception] | None = (source)

Undocumented

_shield_depth: int = (source)

Undocumented

_thread_id: int | None = (source)

Undocumented