From f49114cec5da46880f59dd6a657e1ffd0ad6d019 Mon Sep 17 00:00:00 2001 From: furkan-bilgin Date: Tue, 26 Nov 2024 16:30:19 +0000 Subject: [PATCH] deploy: c1044047e4bcfca0d0441f16e757cdb93532816c --- daq/alert/alert_slack.html | 6 +-- daq/alert/base.html | 4 +- daq/alert/index.html | 4 +- daq/alert/models.html | 6 +-- daq/base.html | 30 +++++++++--- daq/daq_job.html | 4 +- daq/index.html | 4 +- daq/jobs/caen/index.html | 4 +- daq/jobs/caen/n1081b.html | 6 +-- daq/jobs/camera.html | 6 +-- daq/jobs/handle_alerts.html | 8 ++-- daq/jobs/handle_stats.html | 12 +++-- daq/jobs/healthcheck.html | 16 +++---- daq/jobs/index.html | 4 +- daq/jobs/remote.html | 6 +-- daq/jobs/serve_http.html | 8 ++-- daq/jobs/store/csv.html | 10 ++-- daq/jobs/store/index.html | 4 +- daq/jobs/store/mysql.html | 6 +-- daq/jobs/store/raw.html | 10 ++-- daq/jobs/store/redis.html | 12 ++--- daq/jobs/store/root.html | 6 +-- daq/jobs/test_job.html | 8 ++-- daq/models.html | 60 +++++++++++++++--------- daq/store/base.html | 6 +-- daq/store/index.html | 4 +- daq/store/models.html | 46 +++++++++--------- daq/store/types.html | 4 +- daq/types.html | 6 +-- index.html | 4 +- models.html | 4 +- supervisor.html | 93 +++++++++++++++++++++++++++++++++---- utils/file.html | 6 +-- utils/index.html | 4 +- utils/subclasses.html | 4 +- utils/submodules.html | 4 +- utils/time.html | 6 +-- 37 files changed, 275 insertions(+), 160 deletions(-) diff --git a/daq/alert/alert_slack.html b/daq/alert/alert_slack.html index a20575c..8a6541d 100644 --- a/daq/alert/alert_slack.html +++ b/daq/alert/alert_slack.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.alert.alert_slack API documentation @@ -174,7 +174,7 @@

Inherited members

class DAQJobAlertSlackConfig -(slack_webhook_url: str,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(slack_webhook_url: str,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -243,7 +243,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/alert/base.html b/daq/alert/base.html index 84ff7c2..8850e8f 100644 --- a/daq/alert/base.html +++ b/daq/alert/base.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.alert.base API documentation @@ -156,7 +156,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/alert/index.html b/daq/alert/index.html index 529f596..a19989c 100644 --- a/daq/alert/index.html +++ b/daq/alert/index.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.alert API documentation @@ -71,7 +71,7 @@

Sub-modules

diff --git a/daq/alert/models.html b/daq/alert/models.html index 5e1fdbd..1f9b5ce 100644 --- a/daq/alert/models.html +++ b/daq/alert/models.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.alert.models API documentation @@ -210,7 +210,7 @@

Class variables

class DAQJobMessageAlert -(date: datetime.datetime,
alert_info: DAQAlertInfo,
*,
id: Optional[str] = <factory>,
timestamp: Optional[datetime.datetime] = <factory>,
is_remote: bool = False,
daq_job_info: Optional[DAQJobInfo] = None,
remote_config: DAQRemoteConfig = <factory>) +(date: datetime.datetime,
alert_info: DAQAlertInfo,
*,
id: str | None = <factory>,
timestamp: datetime.datetime | None = <factory>,
is_remote: bool = False,
daq_job_info: DAQJobInfo | None = None,
remote_config: DAQRemoteConfig = <factory>)

DAQJobMessage is the base class for messages sent between DAQJobs.

@@ -296,7 +296,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/base.html b/daq/base.html index 87cbbab..8c58fad 100644 --- a/daq/base.html +++ b/daq/base.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.base API documentation @@ -37,7 +37,7 @@

Classes

class DAQJob -(config: Any,
supervisor_config: Optional[SupervisorConfig] = None) +(config: Any,
supervisor_config: SupervisorConfig | None = None)

DAQJob is a base class for data acquisition jobs. It handles the configuration, @@ -172,6 +172,18 @@

Attributes

raise Exception( f"Message type '{type(message)}' is not accepted by '{type(self).__name__}'" ) + # Drop remote messages silently if configured to do so + if self.config.remote_config.drop_remote_messages: + if message.daq_job_info and message.daq_job_info.supervisor_config: + remote_supervisor_id = ( + message.daq_job_info.supervisor_config.supervisor_id + ) + else: + remote_supervisor_id = "unknown" + self._logger.debug( + f"Dropping remote message '{type(message)}' from '{remote_supervisor_id}' because drop_remote_messages is True" + ) + return True return True def start(self): @@ -327,10 +339,10 @@

Raises

class DAQJobThread -(daq_job: DAQJob,
thread: threading.Thread) +(daq_job: DAQJob,
thread: threading.Thread,
start_time: datetime.datetime = <factory>)
-

DAQJobThread(daq_job: enrgdaq.daq.base.DAQJob, thread: threading.Thread)

+

DAQJobThread(daq_job: enrgdaq.daq.base.DAQJob, thread: threading.Thread, start_time: datetime.datetime = )

Expand source code @@ -338,7 +350,8 @@

Raises

@dataclass
 class DAQJobThread:
     daq_job: DAQJob
-    thread: threading.Thread
+ thread: threading.Thread + start_time: datetime = field(default_factory=datetime.now)

Class variables

@@ -346,6 +359,10 @@

Class variables

+
var start_time : datetime.datetime
+
+
+
var thread : threading.Thread
@@ -389,6 +406,7 @@

DAQ

DAQJobThread

@@ -398,7 +416,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/daq_job.html b/daq/daq_job.html index f490f0b..64d1c85 100644 --- a/daq/daq_job.html +++ b/daq/daq_job.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.daq_job API documentation @@ -91,7 +91,7 @@

Functions

diff --git a/daq/index.html b/daq/index.html index dfe8145..e1b2a4e 100644 --- a/daq/index.html +++ b/daq/index.html @@ -3,7 +3,7 @@ - + enrgdaq.daq API documentation @@ -91,7 +91,7 @@

Sub-modules

diff --git a/daq/jobs/caen/index.html b/daq/jobs/caen/index.html index 34fc607..e63bfed 100644 --- a/daq/jobs/caen/index.html +++ b/daq/jobs/caen/index.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.caen API documentation @@ -61,7 +61,7 @@

Sub-modules

diff --git a/daq/jobs/caen/n1081b.html b/daq/jobs/caen/n1081b.html index 6b1ae55..af840cc 100644 --- a/daq/jobs/caen/n1081b.html +++ b/daq/jobs/caen/n1081b.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.caen.n1081b API documentation @@ -200,7 +200,7 @@

Inherited members

class DAQJobN1081BConfig -(store_config: DAQJobStoreConfig,
host: str,
port: str,
password: str,
sections_to_store: list[str],
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(store_config: DAQJobStoreConfig,
host: str,
port: str,
password: str,
sections_to_store: list[str],
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -329,7 +329,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/camera.html b/daq/jobs/camera.html index 71cd97b..cdfa360 100644 --- a/daq/jobs/camera.html +++ b/daq/jobs/camera.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.camera API documentation @@ -128,7 +128,7 @@

Inherited members

class DAQJobCameraConfig -(store_config: DAQJobStoreConfig,
camera_device_index: int = 0,
store_interval_seconds: int = 5,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(store_config: DAQJobStoreConfig,
camera_device_index: int = 0,
store_interval_seconds: int = 5,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

Configuration class for DAQJobCamera.

@@ -199,7 +199,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/handle_alerts.html b/daq/jobs/handle_alerts.html index b30d974..ea0820d 100644 --- a/daq/jobs/handle_alerts.html +++ b/daq/jobs/handle_alerts.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.handle_alerts API documentation @@ -37,7 +37,7 @@

Classes

class DAQJobHandleAlerts -(config: Any,
supervisor_config: Optional[SupervisorConfig] = None) +(config: Any,
supervisor_config: SupervisorConfig | None = None)

DAQJobHandleAlerts is a job that stores alert messages (DAQJobMessageAlert).

@@ -133,7 +133,7 @@

Inherited members

class DAQJobHandleAlertsConfig -(store_config: DAQJobStoreConfig,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(store_config: DAQJobStoreConfig,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

Configuration class for DAQJobHandleAlerts. @@ -191,7 +191,7 @@

diff --git a/daq/jobs/handle_stats.html b/daq/jobs/handle_stats.html index 32595a2..297e3a4 100644 --- a/daq/jobs/handle_stats.html +++ b/daq/jobs/handle_stats.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.handle_stats API documentation @@ -37,7 +37,7 @@

Classes

class DAQJobHandleStats -(config: Any,
supervisor_config: Optional[SupervisorConfig] = None) +(config: Any,
supervisor_config: SupervisorConfig | None = None)

Handles statistics for DAQ jobs.

@@ -69,6 +69,7 @@

Classes

keys = [ "daq_job", + "is_alive", "last_message_in_date", "message_in_count", "last_message_out_date", @@ -93,6 +94,7 @@

Classes

data_to_send.append( [ daq_job_type.__name__, + str(msg.is_alive).lower(), *unpack_record(msg.message_in_stats), *unpack_record(msg.message_out_stats), *unpack_record(msg.restart_stats), @@ -155,7 +157,7 @@

Inherited members

class DAQJobHandleStatsConfig -(store_config: DAQJobStoreConfig,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(store_config: DAQJobStoreConfig,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

Configuration class for DAQJobHandleStats.

@@ -178,7 +180,7 @@

Ancestors

class DAQJobMessageStats -(stats: Dict[type[DAQJob], DAQJobStats],
*,
id: Optional[str] = <factory>,
timestamp: Optional[datetime.datetime] = <factory>,
is_remote: bool = False,
daq_job_info: Optional[DAQJobInfo] = None,
remote_config: DAQRemoteConfig = <factory>) +(stats: Dict[type[DAQJob], DAQJobStats],
*,
id: str | None = <factory>,
timestamp: datetime.datetime | None = <factory>,
is_remote: bool = False,
daq_job_info: DAQJobInfo | None = None,
remote_config: DAQRemoteConfig = <factory>)

Message class containing DAQ job statistics.

@@ -244,7 +246,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/healthcheck.html b/daq/jobs/healthcheck.html index f1756bb..febf4f1 100644 --- a/daq/jobs/healthcheck.html +++ b/daq/jobs/healthcheck.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.healthcheck API documentation @@ -301,7 +301,7 @@

Inherited members

class DAQJobHealthcheckConfig -(healthcheck_stats: list[HealthcheckStatsItem],
enable_alerts_on_restart: bool = True,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(healthcheck_stats: list[HealthcheckStatsItem],
enable_alerts_on_restart: bool = True,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

This class holds the configuration settings for the DAQJobHealthcheck, which is responsible for monitoring the health of the DAQ (Data Acquisition) jobs.

@@ -358,7 +358,7 @@

Instance variables

class HealthcheckItem -(*,
alert_info: DAQAlertInfo,
alive_alert_info: Optional[DAQAlertInfo] = None) +(*,
alert_info: DAQAlertInfo,
alive_alert_info: DAQAlertInfo | None = None)

Represents a healthcheck item with alert information.

@@ -399,7 +399,7 @@

Instance variables

-
var alive_alert_info : Optional[DAQAlertInfo]
+
var alive_alert_info : DAQAlertInfo | None
@@ -407,7 +407,7 @@

Instance variables

class HealthcheckStatsItem -(daq_job_type: str,
stats_key: str,
alert_if_interval_is: AlertCondition,
interval: Optional[str] = None,
amount: Optional[int] = None,
*,
alert_info: DAQAlertInfo,
alive_alert_info: Optional[DAQAlertInfo] = None) +(daq_job_type: str,
stats_key: str,
alert_if_interval_is: AlertCondition,
interval: str | None = None,
amount: int | None = None,
*,
alert_info: DAQAlertInfo,
alive_alert_info: DAQAlertInfo | None = None)

Represents a healthcheck stats item with additional attributes.

@@ -477,7 +477,7 @@

Instance variables

-
var amount : Optional[int]
+
var amount : int | None
@@ -485,7 +485,7 @@

Instance variables

-
var interval : Optional[str]
+
var interval : str | None
@@ -568,7 +568,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/index.html b/daq/jobs/index.html index 78f2ade..26907f2 100644 --- a/daq/jobs/index.html +++ b/daq/jobs/index.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs API documentation @@ -101,7 +101,7 @@

Sub-modules

diff --git a/daq/jobs/remote.html b/daq/jobs/remote.html index 17289fc..5e54d31 100644 --- a/daq/jobs/remote.html +++ b/daq/jobs/remote.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.remote API documentation @@ -333,7 +333,7 @@

Inherited members

class DAQJobRemoteConfig -(zmq_local_url: str,
zmq_remote_urls: list[str],
topics: list[str] = <factory>,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(zmq_local_url: str,
zmq_remote_urls: list[str],
topics: list[str] = <factory>,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

Configuration for DAQJobRemote.

@@ -425,7 +425,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/serve_http.html b/daq/jobs/serve_http.html index 8186966..3113028 100644 --- a/daq/jobs/serve_http.html +++ b/daq/jobs/serve_http.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.serve_http API documentation @@ -37,7 +37,7 @@

Classes

class DAQJobServeHTTP -(config: Any,
supervisor_config: Optional[SupervisorConfig] = None) +(config: Any,
supervisor_config: SupervisorConfig | None = None)

DAQ job to serve HTTP requests.

@@ -163,7 +163,7 @@

Inherited members

class DAQJobServeHTTPConfig -(serve_path: str,
host: str,
port: int,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(serve_path: str,
host: str,
port: int,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

Configuration class for DAQJobServeHTTP.

@@ -253,7 +253,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/store/csv.html b/daq/jobs/store/csv.html index 73a8e93..b91763d 100644 --- a/daq/jobs/store/csv.html +++ b/daq/jobs/store/csv.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.store.csv API documentation @@ -37,7 +37,7 @@

Classes

class CSVFile -(file: ,
last_flush_date: datetime.datetime,
write_queue: collections.deque[list[typing.Any]],
overwrite: Optional[bool] = None) +(file: ,
last_flush_date: datetime.datetime,
write_queue: collections.deque[list[typing.Any]],
overwrite: bool | None = None)

CSVFile(file: , last_flush_date: datetime.datetime, write_queue: collections.deque[list[typing.Any]], overwrite: Optional[bool] = None)

@@ -62,7 +62,7 @@

Class variables

-
var overwrite : Optional[bool]
+
var overwrite : bool | None
@@ -257,7 +257,7 @@

Inherited members

class DAQJobStoreCSVConfig -(out_dir: str = 'out/',
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(out_dir: str = 'out/',
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -336,7 +336,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/store/index.html b/daq/jobs/store/index.html index 7e8b1e1..701447c 100644 --- a/daq/jobs/store/index.html +++ b/daq/jobs/store/index.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.store API documentation @@ -81,7 +81,7 @@

Sub-modules

diff --git a/daq/jobs/store/mysql.html b/daq/jobs/store/mysql.html index 6576ab2..3b65281 100644 --- a/daq/jobs/store/mysql.html +++ b/daq/jobs/store/mysql.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.store.mysql API documentation @@ -181,7 +181,7 @@

Inherited members

class DAQJobStoreMySQLConfig -(host: str,
user: str,
password: str,
database: str,
port: int = 3306,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(host: str,
user: str,
password: str,
database: str,
port: int = 3306,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -315,7 +315,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/store/raw.html b/daq/jobs/store/raw.html index b9c9404..62ca442 100644 --- a/daq/jobs/store/raw.html +++ b/daq/jobs/store/raw.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.store.raw API documentation @@ -205,7 +205,7 @@

Inherited members

class DAQJobStoreRawConfig -(out_dir: str = 'out/',
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(out_dir: str = 'out/',
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -241,7 +241,7 @@

Instance variables

class RawFile -(file: Any,
last_flush_date: datetime.datetime,
write_queue: collections.deque[bytes],
overwrite: Optional[bool] = None) +(file: Any,
last_flush_date: datetime.datetime,
write_queue: collections.deque[bytes],
overwrite: bool | None = None)

RawFile(file: Any, last_flush_date: datetime.datetime, write_queue: collections.deque[bytes], overwrite: Optional[bool] = None)

@@ -266,7 +266,7 @@

Class variables

-
var overwrite : Optional[bool]
+
var overwrite : bool | None
@@ -321,7 +321,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/store/redis.html b/daq/jobs/store/redis.html index f0cd34c..4342bef 100644 --- a/daq/jobs/store/redis.html +++ b/daq/jobs/store/redis.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.store.redis API documentation @@ -228,7 +228,7 @@

Inherited members

class DAQJobStoreRedisConfig -(host: str,
port: int = 6379,
db: int = 0,
password: Optional[str] = None,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(host: str,
port: int = 6379,
db: int = 0,
password: str | None = None,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -267,7 +267,7 @@

Instance variables

-
var password : Optional[str]
+
var password : str | None
@@ -279,7 +279,7 @@

Instance variables

class RedisWriteQueueItem -(store_config: DAQJobStoreConfigRedis,
data: dict[str, list[typing.Any]],
tag: Optional[str]) +(store_config: DAQJobStoreConfigRedis,
data: dict[str, list[typing.Any]],
tag: str | None)

RedisWriteQueueItem(store_config: enrgdaq.daq.store.models.DAQJobStoreConfigRedis, data: dict[str, list[typing.Any]], tag: Optional[str])

@@ -303,7 +303,7 @@

Class variables

-
var tag : Optional[str]
+
var tag : str | None
@@ -356,7 +356,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/store/root.html b/daq/jobs/store/root.html index 5663bb9..18d1791 100644 --- a/daq/jobs/store/root.html +++ b/daq/jobs/store/root.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.store.root API documentation @@ -154,7 +154,7 @@

Inherited members

class DAQJobStoreROOTConfig -(*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -213,7 +213,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/jobs/test_job.html b/daq/jobs/test_job.html index f2ae8b9..d216e28 100644 --- a/daq/jobs/test_job.html +++ b/daq/jobs/test_job.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.jobs.test_job API documentation @@ -37,7 +37,7 @@

Classes

class DAQJobTest -(config: Any,
supervisor_config: Optional[SupervisorConfig] = None) +(config: Any,
supervisor_config: SupervisorConfig | None = None)

A test job for the DAQ system that generates random data.

@@ -149,7 +149,7 @@

Inherited members

class DAQJobTestConfig -(store_config: DAQJobStoreConfig,
rand_min: int,
rand_max: int,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(store_config: DAQJobStoreConfig,
rand_min: int,
rand_max: int,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

Configuration class for DAQJobTest.

@@ -232,7 +232,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/models.html b/daq/models.html index f810868..8ab6096 100644 --- a/daq/models.html +++ b/daq/models.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.models API documentation @@ -37,7 +37,7 @@

Classes

class DAQJobConfig -(*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -91,7 +91,7 @@

Instance variables

-
var remote_config : Optional[DAQRemoteConfig]
+
var remote_config : DAQRemoteConfig | None
@@ -103,7 +103,7 @@

Instance variables

class DAQJobInfo -(daq_job_type: str,
daq_job_class_name: str,
unique_id: str,
instance_id: int,
supervisor_config: Optional[SupervisorConfig] = None) +(daq_job_type: str,
daq_job_class_name: str,
unique_id: str,
instance_id: int,
supervisor_config: SupervisorConfig | None = None)

A class to represent the information of a DAQJob.

@@ -169,7 +169,7 @@

Class variables

-
var supervisor_config : Optional[SupervisorConfig]
+
var supervisor_config : SupervisorConfig | None
@@ -190,7 +190,7 @@

Static methods

class DAQJobMessage -(*,
id: Optional[str] = <factory>,
timestamp: Optional[datetime.datetime] = <factory>,
is_remote: bool = False,
daq_job_info: Optional[DAQJobInfo] = None,
remote_config: DAQRemoteConfig = <factory>) +(*,
id: str | None = <factory>,
timestamp: datetime.datetime | None = <factory>,
is_remote: bool = False,
daq_job_info: DAQJobInfo | None = None,
remote_config: DAQRemoteConfig = <factory>)

DAQJobMessage is the base class for messages sent between DAQJobs.

@@ -242,11 +242,11 @@

Subclasses

Instance variables

-
var daq_job_info : Optional[DAQJobInfo]
+
var daq_job_info : DAQJobInfo | None
-
var id : Optional[str]
+
var id : str | None
@@ -258,7 +258,7 @@

Instance variables

-
var timestamp : Optional[datetime.datetime]
+
var timestamp : datetime.datetime | None
@@ -266,7 +266,7 @@

Instance variables

class DAQJobMessageStop -(reason: str,
*,
id: Optional[str] = <factory>,
timestamp: Optional[datetime.datetime] = <factory>,
is_remote: bool = False,
daq_job_info: Optional[DAQJobInfo] = None,
remote_config: DAQRemoteConfig = <factory>) +(reason: str,
*,
id: str | None = <factory>,
timestamp: datetime.datetime | None = <factory>,
is_remote: bool = False,
daq_job_info: DAQJobInfo | None = None,
remote_config: DAQRemoteConfig = <factory>)

DAQJobMessage is the base class for messages sent between DAQJobs.

@@ -306,7 +306,7 @@

Instance variables

class DAQJobStats -(message_in_stats: DAQJobStatsRecord = <factory>,
message_out_stats: DAQJobStatsRecord = <factory>,
restart_stats: DAQJobStatsRecord = <factory>) +(message_in_stats: DAQJobStatsRecord = <factory>,
message_out_stats: DAQJobStatsRecord = <factory>,
restart_stats: DAQJobStatsRecord = <factory>,
is_alive: bool = True)

A class to represent statistics for a DAQJob. Gets created and updated by Supervisor.

@@ -318,6 +318,8 @@

Attributes

The statistics for outgoing messages.
restart_stats : DAQJobStatsRecord
The statistics for restarts.
+
is_alive : bool
+
Whether the DAQJob is alive.
@@ -331,11 +333,13 @@

Attributes

message_in_stats (DAQJobStatsRecord): The statistics for incoming messages. message_out_stats (DAQJobStatsRecord): The statistics for outgoing messages. restart_stats (DAQJobStatsRecord): The statistics for restarts. + is_alive (bool): Whether the DAQJob is alive. """ message_in_stats: DAQJobStatsRecord = field(default_factory=DAQJobStatsRecord) message_out_stats: DAQJobStatsRecord = field(default_factory=DAQJobStatsRecord) - restart_stats: DAQJobStatsRecord = field(default_factory=DAQJobStatsRecord) + restart_stats: DAQJobStatsRecord = field(default_factory=DAQJobStatsRecord) + is_alive: bool = True

Ancestors

    @@ -344,6 +348,10 @@

    Ancestors

Instance variables

+
var is_alive : bool
+
+
+
var message_in_stats : DAQJobStatsRecord
@@ -360,7 +368,7 @@

Instance variables

class DAQJobStatsRecord -(count: int = 0, last_updated: Optional[datetime.datetime] = None) +(count: int = 0, last_updated: datetime.datetime | None = None)

A class to represent a record of statistics for a DAQJob.

@@ -402,7 +410,7 @@

Instance variables

-
var last_updated : Optional[datetime.datetime]
+
var last_updated : datetime.datetime | None
@@ -439,7 +447,7 @@

Ancestors

class DAQRemoteConfig -(*, remote_topic: Optional[str] = 'DAQ', remote_disable: Optional[bool] = False) +(*,
remote_topic: str | None = 'DAQ',
remote_disable: bool | None = False,
drop_remote_messages: bool | None = False)

Configuration for remote communication of DAQJobMessages.

@@ -449,7 +457,9 @@

Attributes

remote_topic : Optional[str]
The topic to send the message to for remote communication.
remote_disable : Optional[bool]
-
Whether to disable remote communication.
+
Whether to send messages from this DAQ job to remote. If True, messages will not be sent to any remote.
+
drop_remote_messages : Optional[bool]
+
Whether to drop remote messages. If True, messages from remote will not be processed, but messages may still be sent to remote.
@@ -463,11 +473,13 @@

Attributes

Attributes: remote_topic (Optional[str]): The topic to send the message to for remote communication. - remote_disable (Optional[bool]): Whether to disable remote communication. + remote_disable (Optional[bool]): Whether to send messages from this DAQ job to remote. If True, messages will not be sent to any remote. + drop_remote_messages (Optional[bool]): Whether to drop remote messages. If True, messages from remote will not be processed, but messages may still be sent to remote. """ remote_topic: Optional[str] = DEFAULT_REMOTE_TOPIC - remote_disable: Optional[bool] = False + remote_disable: Optional[bool] = False + drop_remote_messages: Optional[bool] = False

Ancestors

    @@ -476,11 +488,15 @@

    Ancestors

Instance variables

-
var remote_disable : Optional[bool]
+
var drop_remote_messages : bool | None
+
+
+
+
var remote_disable : bool | None
-
var remote_topic : Optional[str]
+
var remote_topic : str | None
@@ -599,6 +615,7 @@

DAQJobStats

    +
  • is_alive
  • message_in_stats
  • message_out_stats
  • restart_stats
    • @@ -618,6 +635,7 @@

    DAQRemoteConfig

    @@ -638,7 +656,7 @@

    -

    Generated by pdoc 0.11.2.

    +

    Generated by pdoc 0.11.3.

    diff --git a/daq/store/base.html b/daq/store/base.html index 45b46b3..d69ebd4 100644 --- a/daq/store/base.html +++ b/daq/store/base.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.store.base API documentation @@ -37,7 +37,7 @@

    Classes

    class DAQJobStore -(config: Any,
    supervisor_config: Optional[SupervisorConfig] = None)     +(config: Any,
    supervisor_config: SupervisorConfig | None = None)

    DAQJobStore is an abstract base class for data acquisition job stores. It extends the DAQJob class @@ -192,7 +192,7 @@

    -

    Generated by pdoc 0.11.2.

    +

    Generated by pdoc 0.11.3.

    diff --git a/daq/store/index.html b/daq/store/index.html index 9d32a06..1181d5b 100644 --- a/daq/store/index.html +++ b/daq/store/index.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.store API documentation @@ -71,7 +71,7 @@

    Sub-modules

    diff --git a/daq/store/models.html b/daq/store/models.html index c844ad6..03cf216 100644 --- a/daq/store/models.html +++ b/daq/store/models.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.store.models API documentation @@ -37,7 +37,7 @@

    Classes

    class DAQJobMessageStore -(store_config: DAQJobStoreConfig,
    tag: Optional[str] = None,
    *,
    id: Optional[str] = <factory>,
    timestamp: Optional[datetime.datetime] = <factory>,
    is_remote: bool = False,
    daq_job_info: Optional[DAQJobInfo] = None,
    remote_config: DAQRemoteConfig = <factory>)     +(store_config: DAQJobStoreConfig,
    tag: str | None = None,
    *,
    id: str | None = <factory>,
    timestamp: datetime.datetime | None = <factory>,
    is_remote: bool = False,
    daq_job_info: DAQJobInfo | None = None,
    remote_config: DAQRemoteConfig = <factory>)

    DAQJobMessageStore is a class that extends DAQJobMessage and is used to store @@ -100,7 +100,7 @@

    Instance variables

    -
    var tag : Optional[str]
    +
    var tag : str | None
    @@ -108,7 +108,7 @@

    Instance variables

    Methods

    -def get_remote_config(self) ‑> Optional[DAQRemoteConfig] +def get_remote_config(self) ‑> DAQRemoteConfig | None

    Retrieves the remote configuration from the store_config. @@ -124,7 +124,7 @@

    Returns

    class DAQJobMessageStoreRaw -(store_config: DAQJobStoreConfig,
    tag: Optional[str] = None,
    *,
    id: Optional[str] = <factory>,
    timestamp: Optional[datetime.datetime] = <factory>,
    is_remote: bool = False,
    daq_job_info: Optional[DAQJobInfo] = None,
    remote_config: DAQRemoteConfig = <factory>,
    data: bytes)     +(store_config: DAQJobStoreConfig,
    tag: str | None = None,
    *,
    id: str | None = <factory>,
    timestamp: datetime.datetime | None = <factory>,
    is_remote: bool = False,
    daq_job_info: DAQJobInfo | None = None,
    remote_config: DAQRemoteConfig = <factory>,
    data: bytes)

    DAQJobMessageStoreRaw is a class that inherits from DAQJobMessageStore and represents @@ -173,7 +173,7 @@

    Inherited members

    class DAQJobMessageStoreTabular -(store_config: DAQJobStoreConfig,
    tag: Optional[str] = None,
    *,
    id: Optional[str] = <factory>,
    timestamp: Optional[datetime.datetime] = <factory>,
    is_remote: bool = False,
    daq_job_info: Optional[DAQJobInfo] = None,
    remote_config: DAQRemoteConfig = <factory>,
    keys: list[str],
    data: list[list[str | float | int]])     +(store_config: DAQJobStoreConfig,
    tag: str | None = None,
    *,
    id: str | None = <factory>,
    timestamp: datetime.datetime | None = <factory>,
    is_remote: bool = False,
    daq_job_info: DAQJobInfo | None = None,
    remote_config: DAQRemoteConfig = <factory>,
    keys: list[str],
    data: list[list[str | float | int]])

    DAQJobMessageStoreTabular is a class that inherits from DAQJobMessageStore and represents a tabular data store for DAQ job messages.

    @@ -228,7 +228,7 @@

    Inherited members

    class DAQJobStoreConfig -(csv: Optional[DAQJobStoreConfigCSV] = None,
    root: Optional[DAQJobStoreConfigROOT] = None,
    mysql: Optional[DAQJobStoreConfigMySQL] = None,
    redis: Optional[DAQJobStoreConfigRedis] = None,
    raw: Optional[DAQJobStoreConfigRaw] = None)     +(csv: DAQJobStoreConfigCSV | None = None,
    root: DAQJobStoreConfigROOT | None = None,
    mysql: DAQJobStoreConfigMySQL | None = None,
    redis: DAQJobStoreConfigRedis | None = None,
    raw: DAQJobStoreConfigRaw | None = None)

    Used to store the configuration of the DAQ Job Store, usually inside DAQJobConfig.

    @@ -263,23 +263,23 @@

    Ancestors

Instance variables

-
var csv : Optional[DAQJobStoreConfigCSV]
+
var csv : DAQJobStoreConfigCSV | None
-
var mysql : Optional[DAQJobStoreConfigMySQL]
+
var mysql : DAQJobStoreConfigMySQL | None
-
var raw : Optional[DAQJobStoreConfigRaw]
+
var raw : DAQJobStoreConfigRaw | None
-
var redis : Optional[DAQJobStoreConfigRedis]
+
var redis : DAQJobStoreConfigRedis | None
-
var root : Optional[DAQJobStoreConfigROOT]
+
var root : DAQJobStoreConfigROOT | None
@@ -296,7 +296,7 @@

Methods

class DAQJobStoreConfigBase -(*,
remote_config: Optional[DAQRemoteConfig] = None) +(*,
remote_config: DAQRemoteConfig | None = None)

DAQJobStoreConfigBase is a configuration class for DAQ job store, @@ -336,7 +336,7 @@

Subclasses

Instance variables

-
var remote_config : Optional[DAQRemoteConfig]
+
var remote_config : DAQRemoteConfig | None
@@ -344,7 +344,7 @@

Instance variables

class DAQJobStoreConfigCSV -(file_path: str,
add_date: bool = False,
overwrite: bool = False,
use_gzip: bool = False,
*,
remote_config: Optional[DAQRemoteConfig] = None) +(file_path: str,
add_date: bool = False,
overwrite: bool = False,
use_gzip: bool = False,
*,
remote_config: DAQRemoteConfig | None = None)

DAQJobStoreConfigBase is a configuration class for DAQ job store, @@ -407,7 +407,7 @@

Instance variables

class DAQJobStoreConfigMySQL -(table_name: str,
*,
remote_config: Optional[DAQRemoteConfig] = None) +(table_name: str,
*,
remote_config: DAQRemoteConfig | None = None)

DAQJobStoreConfigBase is a configuration class for DAQ job store, @@ -440,7 +440,7 @@

Instance variables

class DAQJobStoreConfigROOT -(file_path: str,
add_date: bool,
*,
remote_config: Optional[DAQRemoteConfig] = None) +(file_path: str,
add_date: bool,
*,
remote_config: DAQRemoteConfig | None = None)

DAQJobStoreConfigBase is a configuration class for DAQ job store, @@ -478,7 +478,7 @@

Instance variables

class DAQJobStoreConfigRaw -(file_path: str,
add_date: bool = False,
overwrite: bool = True,
*,
remote_config: Optional[DAQRemoteConfig] = None) +(file_path: str,
add_date: bool = False,
overwrite: bool = True,
*,
remote_config: DAQRemoteConfig | None = None)

DAQJobStoreConfigBase is a configuration class for DAQ job store, @@ -532,7 +532,7 @@

Instance variables

class DAQJobStoreConfigRedis -(key: str,
key_expiration_days: Optional[int] = None,
use_timeseries: Optional[bool] = None,
*,
remote_config: Optional[DAQRemoteConfig] = None) +(key: str,
key_expiration_days: int | None = None,
use_timeseries: bool | None = None,
*,
remote_config: DAQRemoteConfig | None = None)

DAQJobStoreConfigBase is a configuration class for DAQ job store, @@ -584,12 +584,12 @@

Instance variables

Data keys will be prefixed with the redis_key, e.g. for the data key "test", the redis key will be "redis_key.test".

If the expiration is set, the key will be prefixed with the date, e.g. for the data key "test", the redis key will be "redis_key.test:2023-01-01".

-
var key_expiration_days : Optional[int]
+
var key_expiration_days : int | None

Delete keys older than this number of days.

If None, keys will not be deleted.

-
var use_timeseries : Optional[bool]
+
var use_timeseries : bool | None

Utilize Redis Timeseries to store data.

A key called "timestamp" is requires when using timeseries.

@@ -598,7 +598,7 @@

Instance variables

class StorableDAQJobConfig -(store_config: DAQJobStoreConfig,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: Optional[DAQRemoteConfig] = <factory>,
daq_job_type: str) +(store_config: DAQJobStoreConfig,
*,
verbosity: LogVerbosity = LogVerbosity.INFO,
remote_config: DAQRemoteConfig | None = <factory>,
daq_job_type: str)

DAQJobConfig is the base configuration class for DAQJobs.

@@ -743,7 +743,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/daq/store/types.html b/daq/store/types.html index 9df528a..f0281e9 100644 --- a/daq/store/types.html +++ b/daq/store/types.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.store.types API documentation @@ -49,7 +49,7 @@

Module enrgdaq.daq.store.types

diff --git a/daq/types.html b/daq/types.html index dcadedd..08db5bd 100644 --- a/daq/types.html +++ b/daq/types.html @@ -3,7 +3,7 @@ - + enrgdaq.daq.types API documentation @@ -40,7 +40,7 @@

Functions

-def get_daq_job_class(daq_job_type: str, warn_deprecated: bool = False) ‑> Optional[type[DAQJob]] +def get_daq_job_class(daq_job_type: str, warn_deprecated: bool = False) ‑> type[DAQJob] | None

Gets the DAQJob class for a given DAQ job type.

@@ -82,7 +82,7 @@

Returns

diff --git a/index.html b/index.html index 77fe324..0d8b952 100644 --- a/index.html +++ b/index.html @@ -3,7 +3,7 @@ - + enrgdaq API documentation @@ -71,7 +71,7 @@

Sub-modules

diff --git a/models.html b/models.html index f397cbe..116c716 100644 --- a/models.html +++ b/models.html @@ -3,7 +3,7 @@ - + enrgdaq.models API documentation @@ -112,7 +112,7 @@

-

Generated by pdoc 0.11.2.

+

Generated by pdoc 0.11.3.

diff --git a/supervisor.html b/supervisor.html index 7cbf283..d48b023 100644 --- a/supervisor.html +++ b/supervisor.html @@ -3,7 +3,7 @@ - + enrgdaq.supervisor API documentation @@ -29,6 +29,25 @@

Module enrgdaq.supervisor

+

Global variables

+
+
var DAQ_JOB_MARK_AS_ALIVE_TIME_SECONDS
+
+

Time in seconds to mark a DAQ job as alive after it has been running for that long.

+
+
var DAQ_JOB_QUEUE_ACTION_TIMEOUT
+
+

Time in seconds to wait for a DAQ job to process a message.

+
+
var DAQ_SUPERVISOR_SLEEP_TIME_SECONDS
+
+

Time in seconds to sleep between iterations of the supervisor's main loop.

+
+
var DAQ_SUPERVISOR_STATS_MESSAGE_INTERVAL_SECONDS
+
+

Time in seconds between sending supervisor stats messages.

+
+
@@ -83,6 +102,8 @@

Attributes

List of schedules for restarting DAQ jobs.
_logger : logging.Logger
Logger instance for logging supervisor activities.
+
_last_stats_message_time : datetime
+
Last time a stats message was sent.

@@ -97,6 +118,7 @@

Attributes

daq_job_stats (DAQJobStatsDict): Dictionary holding statistics for each DAQ job type. restart_schedules (list[RestartDAQJobSchedule]): List of schedules for restarting DAQ jobs. _logger (logging.Logger): Logger instance for logging supervisor activities. + _last_stats_message_time (datetime): Last time a stats message was sent. """ daq_job_threads: list[DAQJobThread] @@ -104,6 +126,8 @@

Attributes

restart_schedules: list[RestartDAQJobSchedule] _logger: logging.Logger + _last_stats_message_time: datetime + def init(self): """ Initializes the supervisor, loads configuration, starts DAQ job threads, and warns for lack of DAQ jobs. @@ -124,6 +148,10 @@

Attributes

} self.warn_for_lack_of_daq_jobs() + self._last_stats_message_time = datetime.now() - timedelta( + seconds=DAQ_SUPERVISOR_STATS_MESSAGE_INTERVAL_SECONDS + ) + def start_daq_job_threads(self) -> list[DAQJobThread]: return start_daq_jobs(load_daq_jobs("configs/", self.config)) @@ -159,7 +187,10 @@

Attributes

# Restart jobs that have stopped or are scheduled to restart self.restart_daq_jobs() - # Get messages from enrgdaq.daq. Jobs + # Handle thread alive stats for dead & alive threads + self.handle_thread_alive_stats(dead_threads) + + # Get messages from DAQ Jobs daq_messages_out = self.get_messages_from_daq_jobs() # Add supervisor messages @@ -168,6 +199,28 @@

Attributes

# Send messages to appropriate DAQ Jobs self.send_messages_to_daq_jobs(daq_messages_out) + def handle_thread_alive_stats(self, dead_threads: list[DAQJobThread]): + """ + Handles the alive stats for the dead threads. + + Args: + dead_threads (list[DAQJobThread]): List of dead threads. + """ + + for thread in self.daq_job_threads: + if ( + datetime.now() + timedelta(seconds=DAQ_JOB_MARK_AS_ALIVE_TIME_SECONDS) + < thread.start_time + ): + self.get_daq_job_stats( + self.daq_job_stats, type(thread.daq_job) + ).is_alive = True + + for thread in dead_threads: + self.get_daq_job_stats( + self.daq_job_stats, type(thread.daq_job) + ).is_alive = False + def get_restart_schedules(self, dead_threads: list[DAQJobThread]): """ Gets the restart schedules for the dead threads. @@ -237,12 +290,16 @@

Attributes

messages = [] # Send stats message - messages.append( - DAQJobMessageStats( - stats=self.daq_job_stats, - daq_job_info=self._get_supervisor_daq_job_info(), + if datetime.now() > self._last_stats_message_time + timedelta( + seconds=DAQ_SUPERVISOR_STATS_MESSAGE_INTERVAL_SECONDS + ): + self._last_stats_message_time = datetime.now() + messages.append( + DAQJobMessageStats( + stats=self.daq_job_stats, + daq_job_info=self._get_supervisor_daq_job_info(), + ) ) - ) return messages def get_daq_job_stats( @@ -386,6 +443,17 @@

Returns

List of supervisor messages.
+
+def handle_thread_alive_stats(self,
dead_threads: list[DAQJobThread]) +
+
+

Handles the alive stats for the dead threads.

+

Args

+
+
dead_threads : list[DAQJobThread]
+
List of dead threads.
+
+
def init(self)
@@ -449,6 +517,14 @@

Args

  • enrgdaq
    • +

  • Global variables

    + +

  • Classes

    • @@ -468,6 +544,7 @@

      get_messages_from_daq_jobs

    • get_restart_schedules
    • get_supervisor_messages
      • +
    • handle_thread_alive_stats
    • init
    • loop
    • restart_daq_jobs
      • @@ -484,7 +561,7 @@

      -

      Generated by pdoc 0.11.2.

      +

      Generated by pdoc 0.11.3.

      diff --git a/utils/file.html b/utils/file.html index 050afe3..916dd0e 100644 --- a/utils/file.html +++ b/utils/file.html @@ -3,7 +3,7 @@ - + enrgdaq.utils.file API documentation @@ -34,7 +34,7 @@

      Module enrgdaq.utils.file

      Functions

      -def modify_file_path(file_path: str, add_date: bool, tag: Optional[str]) ‑> str +def modify_file_path(file_path: str, add_date: bool, tag: str | None) ‑> str

      Modifies a file path by adding a date and/or a tag.

      @@ -81,7 +81,7 @@

      Example

      diff --git a/utils/index.html b/utils/index.html index 2ff65d2..9f9f065 100644 --- a/utils/index.html +++ b/utils/index.html @@ -3,7 +3,7 @@ - + enrgdaq.utils API documentation @@ -76,7 +76,7 @@

      Sub-modules

      diff --git a/utils/subclasses.html b/utils/subclasses.html index 9bb6faa..28298da 100644 --- a/utils/subclasses.html +++ b/utils/subclasses.html @@ -3,7 +3,7 @@ - + enrgdaq.utils.subclasses API documentation @@ -73,7 +73,7 @@

      Returns

      diff --git a/utils/submodules.html b/utils/submodules.html index 8d7959c..371c70d 100644 --- a/utils/submodules.html +++ b/utils/submodules.html @@ -3,7 +3,7 @@ - + enrgdaq.utils.submodules API documentation @@ -66,7 +66,7 @@

      Functions

      diff --git a/utils/time.html b/utils/time.html index 3372a06..eb90f99 100644 --- a/utils/time.html +++ b/utils/time.html @@ -3,7 +3,7 @@ - + enrgdaq.utils.time API documentation @@ -46,7 +46,7 @@

      Functions

      -def sleep_for(seconds: float, start_time: Optional[datetime.datetime] = None) +def sleep_for(seconds: float, start_time: datetime.datetime | None = None)
      @@ -77,7 +77,7 @@

      Functions