Orchestration Engine

Task orchestration engine built on Dagster for executing computational jobs as directed acyclic graphs (DAGs). Integrates with the device manager to coordinate protocol execution.

• orchestration_engine
  • orchestration_engine.assets
    • orchestration_engine.assets.acquisition_data
    • orchestration_engine.assets.dicom_input
    • orchestration_engine.assets.image_processing
    • orchestration_engine.assets.mrpro_direct_reconstruction
  • orchestration_engine.io
    • orchestration_engine.io.base
    • orchestration_engine.io.dicom_io_manager
    • orchestration_engine.io.idata_io_manager
  • orchestration_engine.jobs
    • orchestration_engine.jobs.acquisition_data
  • orchestration_engine.notifier
  • orchestration_engine.repository
  • orchestration_engine.resources
  • orchestration_engine.sensors
  • orchestration_engine.utils
    • orchestration_engine.utils.dag_config
    • orchestration_engine.utils.snr