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, Path]])