temporalio.worker._activity._ThreadExceptionRaiser

class documentation

class _ThreadExceptionRaiser: (source)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method raise_in_thread Undocumented
Method set_thread_id Undocumented
Method shielded Undocumented
Method _raise_in_thread_if_pending_unlocked Undocumented
Instance Variable _lock Undocumented
Instance Variable _pending_exception Undocumented
Instance Variable _shield_depth Undocumented
Instance Variable _thread_id Undocumented
def __init__(self): (source)

Undocumented

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

Undocumented

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

Undocumented

@contextmanager
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