temporalio.worker._tuning._BridgeSlotSupplierWrapper

class documentation

class _BridgeSlotSupplierWrapper: (source)

Constructor: _BridgeSlotSupplierWrapper(supplier)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method mark_slot_used Undocumented
Method release_slot Undocumented
Async Method reserve_slot Undocumented
Method try_reserve_slot Undocumented
Instance Variable _supplier Undocumented
def __init__(self, supplier: CustomSlotSupplier): (source)

Undocumented

def mark_slot_used(self, ctx: SlotMarkUsedContext): (source)

Undocumented

def release_slot(self, ctx: SlotReleaseContext): (source)

Undocumented

async def reserve_slot(self, ctx: SlotReserveContext, reserve_cb: Callable[[Any], None]) -> SlotPermit: (source)

Undocumented

def try_reserve_slot(self, ctx: SlotReserveContext) -> SlotPermit | None: (source)

Undocumented

_supplier = (source)

Undocumented