resonate.stores.remote.RemoteTaskStore

class documentation

class RemoteTaskStore:

Constructor: RemoteTaskStore(url, call, encoder)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method claim Undocumented
Method complete Undocumented
Method heartbeat Undocumented
Instance Variable url Undocumented
Instance Variable _call Undocumented
Instance Variable _encoder Undocumented
def __init__(self, url: str, call: Callable[[requests.Request], requests.Response], encoder: IEncoder[str, str]):

Undocumented

def claim(self, *, task_id: str, counter: int, pid: str, ttl: int) -> InvokeMsg | ResumeMsg:

Undocumented

def complete(self, *, task_id: str, counter: int):

Undocumented

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

Undocumented

url =

Undocumented

_call =

Undocumented

_encoder =

Undocumented