archivebox.queues.supervisor_util

Module Contents

Functions

follow

Yield each line from a file as they are written. sleep_sec is the time to sleep after empty reads.

create_supervisord_config

create_worker_config

get_existing_supervisord_process

stop_existing_supervisord_process

start_new_supervisord_process

get_or_create_supervisord_process

start_worker

watch_worker

loop continuously and monitor worker’s health

tail_worker_logs

get_worker

stop_worker

start_server_workers

start_cli_workers

Data

__package__

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)