From 43c7a18ae211527d04e6d180bba8d1531d071764 Mon Sep 17 00:00:00 2001
From: Tito Dal Canton <tito.dalcanton@ijclab.in2p3.fr>
Date: Thu, 1 Aug 2024 13:53:53 +0200
Subject: [PATCH] Same fixes for singles

---
 pycbc/events/coinc.py  |  8 +++-----
 pycbc/events/single.py | 24 +++++++++++-------------
 2 files changed, 14 insertions(+), 18 deletions(-)

diff --git a/pycbc/events/coinc.py b/pycbc/events/coinc.py
index 5ac7c593e61..ee729a97bcc 100644
--- a/pycbc/events/coinc.py
+++ b/pycbc/events/coinc.py
@@ -1431,7 +1431,7 @@ def refresh_statistic(self):
                 self.time_stat_refreshed = timemod.time()
                 logger.info(
                     "Checking %s statistic for updated files",
-                    ''.join(self.ifos),
+                    ppdets(self.ifos, "-"),
                 )
                 with self.stat_calculator_lock:
                     self.stat_calculator.check_update_files()
@@ -1441,12 +1441,10 @@ def refresh_statistic(self):
             since_stat_refresh = timemod.time() - self.time_stat_refreshed
             logger.debug(
                 "%s statistic: Waiting %.3fs for next refresh",
-                ''.join(self.ifos),
+                ppdets(self.ifos, "-"),
                 self.statistic_refresh_rate - since_stat_refresh,
             )
-            timemod.sleep(
-                self.statistic_refresh_rate - since_stat_refresh + 1
-            )
+            timemod.sleep(self.statistic_refresh_rate - since_stat_refresh + 1)
 
 
 __all__ = [
diff --git a/pycbc/events/single.py b/pycbc/events/single.py
index e62b3d8379d..db22fd08712 100644
--- a/pycbc/events/single.py
+++ b/pycbc/events/single.py
@@ -3,7 +3,6 @@
 import logging
 import copy
 import threading
-from datetime import datetime as dt
 import time
 import numpy as np
 
@@ -76,7 +75,7 @@ class (in seconds), default not do do this
         self.fixed_ifar = fixed_ifar
         self.maximum_ifar = maximum_ifar
 
-        self.time_stat_refreshed = dt.now()
+        self.time_stat_refreshed = time.time()
         self.stat_calculator_lock = threading.Lock()
         self.statistic_refresh_rate = statistic_refresh_rate
 
@@ -360,9 +359,13 @@ def start_refresh_thread(self):
         """
         Start a thread managing whether the stat_calculator will be updated
         """
+        if self.statistic_refresh_rate is None:
+            logger.info("Statistic refresh disabled for %s", self.ifo)
+            return
         thread = threading.Thread(
             target=self.refresh_statistic,
-            daemon=True
+            daemon=True,
+            name="Stat refresh " + self.ifo
         )
         logger.info("Starting %s statistic refresh thread", self.ifo)
         thread.start()
@@ -373,26 +376,21 @@ def refresh_statistic(self):
         """
         while True:
             # How long since the statistic was last updated?
-            since_stat_refresh = \
-                (dt.now() - self.time_stat_refreshed).total_seconds()
+            since_stat_refresh = time.time() - self.time_stat_refreshed
             if since_stat_refresh > self.statistic_refresh_rate:
-                self.time_stat_refreshed = dt.now()
+                self.time_stat_refreshed = time.time()
                 logger.info(
-                    "Checking %s statistic for updated files",
-                    self.ifo,
+                    "Checking %s statistic for updated files", self.ifo
                 )
                 with self.stat_calculator_lock:
                     self.stat_calculator.check_update_files()
             # Sleep one second for safety
             time.sleep(1)
             # Now use the time it took the check / update the statistic
-            since_stat_refresh = \
-                (dt.now() - self.time_stat_refreshed).total_seconds()
+            since_stat_refresh = time.time() - self.time_stat_refreshed
             logger.debug(
                 "%s statistic: Waiting %.3fs for next refresh",
                 self.ifo,
                 self.statistic_refresh_rate - since_stat_refresh
             )
-            time.sleep(
-                self.statistic_refresh_rate - since_stat_refresh
-            )
+            time.sleep(self.statistic_refresh_rate - since_stat_refresh)