hpcflow.sdk.helper.watcher.WorkflowMonitor#

class hpcflow.sdk.helper.watcher.WorkflowMonitor(workflow_paths, watch_interval, logger)#

Bases: object

Workflow monitor.

Methods

on_modified

Triggered on a workflow being modified.

stop

Stop this monitor.

update_workflow_paths

Change the set of paths to monitored workflows.
Parameters:

  • workflow_paths (list[dict[str, Path]]) –

  • watch_interval (float | timedelta) –

  • logger (Logger) –

on_modified(event)#

Triggered on a workflow being modified.

Parameters:

event (FileSystemEvent) –

stop()#

Stop this monitor.

Return type:

None

update_workflow_paths(new_paths)#

Change the set of paths to monitored workflows.

Parameters:

new_paths (list[dict[str, pathlib.Path]]) –