archivebox.queues.supervisor_util
Module Contents
Functions
Yield each line from a file as they are written.
|
|
loop continuously and monitor worker’s health |
|
Data
API
- archivebox.queues.supervisor_util.__package__
‘archivebox.queues’
- archivebox.queues.supervisor_util.follow(file, sleep_sec=0.1) Iterator[str]
Yield each line from a file as they are written.
sleep_sec
is the time to sleep after empty reads.
- archivebox.queues.supervisor_util.create_supervisord_config()
- archivebox.queues.supervisor_util.create_worker_config(daemon)
- archivebox.queues.supervisor_util.get_existing_supervisord_process()
- archivebox.queues.supervisor_util.stop_existing_supervisord_process()
- archivebox.queues.supervisor_util.start_new_supervisord_process(daemonize=False)
- archivebox.queues.supervisor_util.get_or_create_supervisord_process(daemonize=False)
- archivebox.queues.supervisor_util.start_worker(supervisor, daemon, lazy=False)
- archivebox.queues.supervisor_util.watch_worker(supervisor, daemon_name, interval=5)
loop continuously and monitor worker’s health
- archivebox.queues.supervisor_util.tail_worker_logs(log_path: str)
- archivebox.queues.supervisor_util.get_worker(supervisor, daemon_name)
- archivebox.queues.supervisor_util.stop_worker(supervisor, daemon_name)
- archivebox.queues.supervisor_util.start_server_workers(host='0.0.0.0', port='8000', daemonize=False)
- archivebox.queues.supervisor_util.start_cli_workers(watch=False)