nebius.aio._runtime._StagedLoopExceptionHandler

class documentation

class _StagedLoopExceptionHandler: (source)

Constructor: _StagedLoopExceptionHandler(handler, previous_handler)

View In Hierarchy

Identify one borrowed-loop assignment while installation can fail.

A distinct forwarding callable is installed for every assignment. Its identity prevents an interrupted assignment from mistaking a newer use of the same public handler for its own. A successful installation releases the predecessor, so repeated SDK construction cannot retain old handlers.

Parameters
handlerPublic handler requested by this constructor.
previous_handlerHandler installed before this constructor.
Method __call__ Forward a diagnostic according to the transaction's current state.
Method __init__ Initialize a pending forwarding assignment.
Method commit Release rollback state after successful installation.
Method restorable_predecessor Return the preceding handler without flattening a live proxy.
Method rollback Mark this assignment for removal from a predecessor chain.
Instance Variable handler Undocumented
Instance Variable _state Undocumented
Instance Variable _state_lock Undocumented
def __call__(self, loop: asyncio.AbstractEventLoop, context: dict[str, Any]): (source)

Forward a diagnostic according to the transaction's current state.

def __init__(self, handler: LoopExceptionHandler, previous_handler: _StoredLoopExceptionHandler | None): (source)

Initialize a pending forwarding assignment.

def commit(self): (source)

Release rollback state after successful installation.

def restorable_predecessor(self) -> _StoredLoopExceptionHandler | None: (source)

Return the preceding handler without flattening a live proxy.

def rollback(self): (source)

Mark this assignment for removal from a predecessor chain.

handler = (source)

Undocumented

_state: tuple[str, _StoredLoopExceptionHandler | None] = (source)

Undocumented

_state_lock = (source)

Undocumented