From 562dafa8003f907a1ab05e6769a11b0753ed6d26 Mon Sep 17 00:00:00 2001 From: Ric Evans Date: Tue, 19 Dec 2023 11:27:45 -0600 Subject: [PATCH] rm condor/stopper.py --- ewms_sidecar/condor/stopper.py | 30 ------------------------------ 1 file changed, 30 deletions(-) delete mode 100644 ewms_sidecar/condor/stopper.py diff --git a/ewms_sidecar/condor/stopper.py b/ewms_sidecar/condor/stopper.py deleted file mode 100644 index 79d68f446..000000000 --- a/ewms_sidecar/condor/stopper.py +++ /dev/null @@ -1,30 +0,0 @@ -"""For stopping Skymap Scanner clients on an HTCondor cluster.""" - - -import htcondor # type: ignore[import] - -from ..config import LOGGER - - -def stop( - collector: str, - schedd: str, - cluster_id: str, - schedd_obj: htcondor.Schedd, -) -> None: - """Main logic.""" - LOGGER.info( - f"Stopping Skymap Scanner client workers on {cluster_id} / {collector} / {schedd}" - ) - - # Remove workers -- may not be instantaneous - LOGGER.info("Requesting removal...") - act_obj = schedd_obj.act( - htcondor.JobAction.Remove, - f"ClusterId == {cluster_id}", - reason="Requested by SkyDriver", - ) - LOGGER.debug(act_obj) - LOGGER.info(f"Removed {act_obj['TotalSuccess']} workers") - - # TODO: get/forward worker logs