orchestrator.sensors

Run-status sensors that report job outcomes directly to the protocol manager.

Functions

_get_dag_config_from_run(→ dict)	Extract the DAG configuration dictionary from a RunStatusSensorContext.
on_run_success(→ None)	On successful reconstruction: register DICOM result and push SSE completion event.
on_run_failure(→ None)	On failed reconstruction: mark the task as FAILED and push SSE error event.
on_run_canceled(→ None)	On canceled reconstruction: mark the task as CANCELLED and push SSE event.

Module Contents

orchestrator.sensors._get_dag_config_from_run(context: dagster.RunStatusSensorContext) → dict

Extract the DAG configuration dictionary from a RunStatusSensorContext.

orchestrator.sensors.on_run_success(context: dagster.RunStatusSensorContext, notifier_exam_manager: orchestrator.notifier.ProtocolManagerNotifier, notifier_device_manager: orchestrator.notifier.DeviceManagerNotifier) → None

On successful reconstruction: register DICOM result and push SSE completion event.

orchestrator.sensors.on_run_failure(context: dagster.RunStatusSensorContext, notifier_exam_manager: orchestrator.notifier.ProtocolManagerNotifier, notifier_device_manager: orchestrator.notifier.DeviceManagerNotifier) → None

On failed reconstruction: mark the task as FAILED and push SSE error event.

orchestrator.sensors.on_run_canceled(context: dagster.RunStatusSensorContext, notifier_exam_manager: orchestrator.notifier.ProtocolManagerNotifier, notifier_device_manager: orchestrator.notifier.DeviceManagerNotifier) → None

On canceled reconstruction: mark the task as CANCELLED and push SSE event.