resonate.task_sources.Poller

class documentation

class Poller(ITaskSource):

Constructor: Poller(url, group)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method default_recv Undocumented
Method start Undocumented
Method stop Undocumented
Method _run Undocumented
Instance Variable _encoder Undocumented
Instance Variable _group Undocumented
Instance Variable _t Undocumented
Instance Variable _url Undocumented
def __init__(self, url: str | None = None, group: str | None = None):

Undocumented

def default_recv(self, pid: str) -> dict[str, Any]:
overrides resonate.task_sources.traits.ITaskSource.default_recv

Undocumented

def start(self, cmd_queue: CommandQ, pid: str):
overrides resonate.traits.Subsystem.start

Undocumented

def stop(self):
overrides resonate.traits.Subsystem.stop

Undocumented

@utils.exit_on_exception
def _run(self, cmd_queue: CommandQ, pid: str):

Undocumented

_encoder =

Undocumented

_group =

Undocumented

_t: Thread | None =

Undocumented

_url =

Undocumented