temporalio.worker._nexus._NexusTaskCancellation

class documentation

class _NexusTaskCancellation(nexusrpc.handler.OperationTaskCancellation): (source)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method cancel Undocumented
Method cancellation_reason Undocumented
Method is_cancelled Undocumented
Async Method wait_until_cancelled Undocumented
Method wait_until_cancelled_sync Undocumented
Instance Variable _async_evt Undocumented
Instance Variable _lock Undocumented
Instance Variable _reason Undocumented
Instance Variable _thread_evt Undocumented
def __init__(self): (source)

Undocumented

def cancel(self, reason: str) -> bool: (source)

Undocumented

def cancellation_reason(self) -> str | None: (source)

Undocumented

def is_cancelled(self) -> bool: (source)

Undocumented

async def wait_until_cancelled(self): (source)

Undocumented

def wait_until_cancelled_sync(self, timeout: float | None = None) -> bool: (source)

Undocumented

_async_evt = (source)

Undocumented

_lock = (source)

Undocumented

_reason: str | None = (source)

Undocumented

_thread_evt = (source)

Undocumented