hpcflow.sdk.helper.watcher.MonitorController

class hpcflow.sdk.helper.watcher.MonitorController(workflow_dirs_file_path, watch_interval, logger)

Bases: object

Controller for tracking watch files.

Methods

join	Join the worker thread.
on_modified	Callback when files are modified.
parse_watch_workflows_file	Parse the file describing what workflows to watch.
stop	Stop this monitor.

Parameters:

• workflow_dirs_file_path (str | Path) –

• watch_interval (float | timedelta) –

• logger (Logger) –

join()

Join the worker thread.

Return type:

None

on_modified(event)

Callback when files are modified.

Parameters:

event (FileSystemEvent) –

static parse_watch_workflows_file(path, logger)

Parse the file describing what workflows to watch.

Parameters:

• path (str | Path) –

• logger (Logger) –

Return type:

list[dict[str, pathlib.Path]]

stop()

Stop this monitor.

Return type:

None