mirrors/ArchiveBox
1
0
Fork 0
mirror of https://github.com/ArchiveBox/ArchiveBox.git synced 2025-05-14 15:14:31 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

clear out stale supervisord state in between runs

Browse source
This commit is contained in:
Nick Sweeting 2024-10-08 18:59:48 -07:00
parent 584abe8548
commit 0b4cbb6415
No known key found for this signature in database
1 changed files with 9 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

10
archivebox/queues/supervisor_util.py
View file

@ -3,6 +3,7 @@ __package__ = 'archivebox.queues'
import time import time
import signal import signal
import psutil import psutil
import shutil
import subprocess import subprocess
from pathlib import Path from pathlib import Path
from rich import print from rich import print
@ -85,7 +86,7 @@ def get_existing_supervisord_process():
current_state = cast(Dict[str, int | str], server.supervisor.getState()) current_state = cast(Dict[str, int | str], server.supervisor.getState())
if current_state["statename"] == "RUNNING": if current_state["statename"] == "RUNNING":
pid = server.supervisor.getPID() pid = server.supervisor.getPID()
print(f"[🦸‍♂️] Supervisord connected (pid={pid}) via unix://{str(get_sock_file()).replace(str(TMP_DIR), 'tmp')}.") print(f"[🦸‍♂️] Supervisord connected (pid={pid}) via unix://{str(get_sock_file()).replace(str(DATA_DIR), '.')}.")
return server.supervisor return server.supervisor
except FileNotFoundError: except FileNotFoundError:
return None return None
@ -117,6 +118,13 @@ def stop_existing_supervisord_process():
def start_new_supervisord_process(daemonize=False): def start_new_supervisord_process(daemonize=False):
print(f"[🦸‍♂️] Supervisord starting{' in background' if daemonize else ''}...") print(f"[🦸‍♂️] Supervisord starting{' in background' if daemonize else ''}...")
# Create a config file in the current working directory # Create a config file in the current working directory
# clear out existing stale state files
shutil.rmtree(WORKERS_DIR, ignore_errors=True)
PID_FILE.unlink(missing_ok=True)
get_sock_file().unlink(missing_ok=True)
SUPERVISORD_CONFIG_FILE.unlink(missing_ok=True)
create_supervisord_config() create_supervisord_config()
# Start supervisord # Start supervisord