resonate.stores.local.LocalPromiseStore

class documentation

class LocalPromiseStore:

Constructor: LocalPromiseStore(store)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method callback Undocumented
Method cancel Undocumented
Method create Undocumented
Method create_with_task Undocumented
Method get Undocumented
Method reject Undocumented
Method resolve Undocumented
Method scan Undocumented
Method subscribe Undocumented
Method transition Undocumented
Method _complete Undocumented
Method _create Undocumented
Method _transition Undocumented
Instance Variable _promises Undocumented
Instance Variable _store Undocumented
def __init__(self, store: LocalStore):

Undocumented

def callback(self, promise_id: str, root_promise_id: str, recv: str, timeout: int) -> tuple[DurablePromise, Callback | None]:

Undocumented

def cancel(self, id: str, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: Any = None) -> DurablePromise:

Undocumented

def create(self, id: str, timeout: int, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: Any = None, tags: dict[str, str] | None = None) -> DurablePromise:

Undocumented

def create_with_task(self, id: str, timeout: int, pid: str, ttl: int, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: Any = None, tags: dict[str, str] | None = None) -> tuple[DurablePromise, Task | None]:

Undocumented

def get(self, id: str) -> DurablePromise:

Undocumented

def reject(self, id: str, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: Any = None) -> DurablePromise:

Undocumented

def resolve(self, id: str, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: Any = None) -> DurablePromise:

Undocumented

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

Undocumented

def subscribe(self, id: str, promise_id: str, recv: str, timeout: int) -> tuple[DurablePromise, Callback | None]:

Undocumented

def transition(self, id: str, to: Literal['PENDING', 'RESOLVED', 'REJECTED', 'REJECTED_CANCELED', 'REJECTED_TIMEDOUT'], strict: bool | None = None, timeout: int | None = None, ikey: str | None = None, headers: dict[str, str] | None = None, data: str | None = None, tags: dict[str, str] | None = None) -> tuple[DurablePromiseRecord, TaskRecord | None, bool]:

Undocumented

def _complete(self, id: str, state: Literal['REJECTED_CANCELED', 'REJECTED', 'RESOLVED'], *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: Any = None) -> DurablePromise:

Undocumented

def _create(self, id: str, timeout: int, *, ikey: str | None = None, strict: bool = False, headers: dict[str, str] | None = None, data: Any = None, tags: dict[str, str] | None = None, pid: str | None = None, ttl: int = 0) -> tuple[DurablePromise, Task | None]:

Undocumented

def _transition(self, id: str, to: Literal['PENDING', 'RESOLVED', 'REJECTED', 'REJECTED_CANCELED', 'REJECTED_TIMEDOUT'], strict: bool | None = None, timeout: int | None = None, ikey: str | None = None, headers: dict[str, str] | None = None, data: str | None = None, tags: dict[str, str] | None = None) -> tuple[DurablePromiseRecord, bool]:

Undocumented

_promises: dict[str, DurablePromiseRecord] =

Undocumented

_store =

Undocumented