yarqueue.watch package

Submodules

yarqueue.watch.cli module

class yarqueue.watch.cli.MultiTqdm(redis, names_totals: Dict[str, Optional[int]])

Bases: object

close()

update()

class yarqueue.watch.cli.TqdmQueueWatcher(watcher: yarqueue.watch.common.QueueWatcher, total=None)

Bases: object

close()

n_done()

update()

yarqueue.watch.cli.main(redis, names_totals, interval=1)

yarqueue.watch.common module

class yarqueue.watch.common.QueueWatcher(name, redis: redis.client.Redis = Redis<ConnectionPool<Connection<host=localhost, port=6379, db=0>>>)

Bases: object

queued_inprogress()

yarqueue.watch.common.signal_handler(sig, frame)

yarqueue.watch.http module

class yarqueue.watch.http.JsonQueueWatcher(watcher: yarqueue.watch.common.QueueWatcher, total=None)

Bases: object

status()

class yarqueue.watch.http.MultiJson(redis, names_totals: Dict[str, Optional[int]])

Bases: object

status(names=None)

yarqueue.watch.http.main(host, port, redis, names_totals)

Module contents