parsl.monitoring.MonitoringHub

class parsl.monitoring.MonitoringHub(hub_address: Any = None, hub_port_range: Any = None, hub_port: Any = None, workflow_name: str | None = None, workflow_version: str | None = None, logging_endpoint: str | None = None, monitoring_debug: bool = False, resource_monitoring_enabled: bool = True, resource_monitoring_interval: float = 30)[source]
__init__(hub_address: Any = None, hub_port_range: Any = None, hub_port: Any = None, workflow_name: str | None = None, workflow_version: str | None = None, logging_endpoint: str | None = None, monitoring_debug: bool = False, resource_monitoring_enabled: bool = True, resource_monitoring_interval: float = 30)[source]
Parameters:

  • hub_address (unused)

  • hub_port (unused) – Unused, but probably retained until 2026-06-01 to give deprecation warning. These two values previously configured UDP parameters when UDP was used for monitoring messages from workers. These are now configured on the relevant UDPRadio.

  • hub_port_range (unused) – Unused, but probably retained until 2026-06-01 to give deprecation warning. This value previously configured one ZMQ channel inside the HighThroughputExecutor. That ZMQ channel is now configured by the interchange_port_range parameter of HighThroughputExecutor.

  • workflow_name (str) – The name for the workflow. Default to the name of the parsl script

  • workflow_version (str) – The version of the workflow. Default to the beginning datetime of the parsl script

  • logging_endpoint (str) – The database connection url for monitoring to log the information. These URLs follow RFC-1738, and can include username, password, hostname, database name. Default: sqlite, in the configured run_dir.

  • monitoring_debug (Bool) – Enable monitoring debug logging. Default: False

  • resource_monitoring_enabled (boolean) – Set this field to True to enable logging of information from the worker side. This will include environment information such as start time, hostname and block id, along with periodic resource usage of each task. Default: True

  • resource_monitoring_interval (float) – The time interval, in seconds, at which the monitoring records the resource usage of each task. If set to 0, only start and end information will be logged, and no periodic monitoring will be made. Default: 30 seconds

Methods

__init__([hub_address, hub_port_range, ...])

close()

start(dfk_run_dir, config_run_dir)

close() → None[source]
start(dfk_run_dir: str, config_run_dir: str | PathLike) → None[source]