`archivebox.workers.supervisord_util`

Module Contents

`get_sock_file`	Get the path to the supervisord socket file, symlinking to a shorter path if needed due to unix path length limits
`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`	Create a supervisord worker config file for a given daemon
`get_existing_supervisord_process`
`stop_existing_supervisord_process`
`start_new_supervisord_process`
`get_or_create_supervisord_process`
`start_worker`
`get_worker`
`stop_worker`
`tail_worker_logs`
`watch_worker`	loop continuously and monitor worker’s health
`start_server_workers`
`start_cli_workers`

archivebox.workers.supervisord_util.LOG_FILE_NAME[source]: ‘supervisord.log’

archivebox.workers.supervisord_util.CONFIG_FILE_NAME[source]: ‘supervisord.conf’

archivebox.workers.supervisord_util.PID_FILE_NAME[source]: ‘supervisord.pid’

archivebox.workers.supervisord_util.get_sock_file()[source]: Get the path to the supervisord socket file, symlinking to a shorter path if needed due to unix path length limits

archivebox.workers.supervisord_util.follow(file, sleep_sec=0.1) → Iterator[str][source]: Yield each line from a file as they are written. sleep_sec is the time to sleep after empty reads.

archivebox.workers.supervisord_util.create_worker_config(daemon)[source]: Create a supervisord worker config file for a given daemon

archivebox.workers.supervisord_util.get_existing_supervisord_process()[source]

archivebox.workers.supervisord_util.stop_existing_supervisord_process()[source]

archivebox.workers.supervisord_util.start_new_supervisord_process(daemonize=False)[source]

archivebox.workers.supervisord_util.get_or_create_supervisord_process(daemonize=False)[source]

archivebox.workers.supervisord_util.start_worker(supervisor, daemon, lazy=False)[source]

archivebox.workers.supervisord_util.get_worker(supervisor, daemon_name)[source]

archivebox.workers.supervisord_util.stop_worker(supervisor, daemon_name)[source]

archivebox.workers.supervisord_util.tail_worker_logs(log_path: str)[source]

archivebox.workers.supervisord_util.watch_worker(supervisor, daemon_name, interval=5)[source]: loop continuously and monitor worker’s health

archivebox.workers.supervisord_util.start_server_workers(host='0.0.0.0', port='8000', daemonize=False)[source]

archivebox.workers.supervisord_util.start_cli_workers(watch=False)[source]