resonate.stores.local.LocalTaskStore

class documentation

class LocalTaskStore:

Constructor: LocalTaskStore(store)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method claim Undocumented
Method complete Undocumented
Method heartbeat Undocumented
Method scan Undocumented
Method transition Undocumented
Instance Variable _store Undocumented
Instance Variable _tasks Undocumented
def __init__(self, store: LocalStore):

Undocumented

def claim(self, id: str, counter: int, pid: str, ttl: int) -> tuple[DurablePromise, DurablePromise | None]:

Undocumented

def complete(self, id: str, counter: int) -> bool:

Undocumented

def heartbeat(self, pid: str) -> int:

Undocumented

def scan(self) -> Generator[TaskRecord]:

Undocumented

def transition(self, id: str, to: Literal['INIT', 'ENQUEUED', 'CLAIMED', 'COMPLETED'], *, type: Literal['invoke', 'resume', 'notify'] | None = None, recv: str | None = None, root_promise_id: str | None = None, leaf_promise_id: str | None = None, counter: int | None = None, pid: str | None = None, ttl: int | None = None, force: bool = False) -> tuple[TaskRecord, bool]:

Undocumented

_store =

Undocumented

_tasks: dict[str, TaskRecord] =

Undocumented