orchestrator.sensors
====================

.. py:module:: orchestrator.sensors

.. autoapi-nested-parse::

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



Functions
---------

.. autoapisummary::

   orchestrator.sensors._get_dag_config_from_run
   orchestrator.sensors.on_run_success
   orchestrator.sensors.on_run_failure
   orchestrator.sensors.on_run_canceled


Module Contents
---------------

.. py:function:: _get_dag_config_from_run(context: dagster.RunStatusSensorContext) -> dict

   Extract the DAG configuration dictionary from a RunStatusSensorContext.


.. py:function:: 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.


.. py:function:: 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.


.. py:function:: 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.