resonate.stores.local.LocalPromiseStore

class documentation

class LocalPromiseStore(IPromiseStore):

Constructor: LocalPromiseStore(storage)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method cancel Undocumented
Method create Undocumented
Method create_with_task Undocumented
Method get Undocumented
Method reject Undocumented
Method resolve Undocumented
Instance Variable _storage Undocumented
def __init__(self, storage: IStorage | None = None):

Undocumented

def cancel(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.cancel

Undocumented

def create(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data, timeout: int, tags: Tags) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.create

Undocumented

def create_with_task(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data, timeout: int, tags: Tags, pid: str, ttl: int) -> tuple[DurablePromiseRecord, TaskRecord | None]:
overrides resonate.stores.traits.IPromiseStore.create_with_task

Undocumented

def get(self, *, id: str) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.get

Undocumented

def reject(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.reject

Undocumented

def resolve(self, *, id: str, ikey: str | None, strict: bool, headers: Headers, data: Data) -> DurablePromiseRecord:
overrides resonate.stores.traits.IPromiseStore.resolve

Undocumented

_storage =

Undocumented