|
|
def | __init__ (self) |
| |
|
def | add (self, coordinator) |
| |
|
def | get_new_worker_id (self) |
| |
|
def | get_worker_ids (self) |
| |
|
def | get_queue (self, queue_name, max_buffered_batches) |
| |
|
def | start (self) |
| |
|
def | stop (self) |
| |
|
def | register_shutdown_handler (self) |
| |
Definition at line 349 of file data_workers.py.
The documentation for this class was generated from the following file: