Index

_

__mapper_args__ (app.db.postgres.AcquisitionTask attribute) (app.db.postgres.Task attribute) __table_args__ (app.api.db.Patient attribute) (app.db.postgres.Protocol attribute) (app.db.postgres.Result attribute) (app.db.postgres.Task attribute) (app.db.UserSQL attribute) __tablename__ (app.api.db.Patient attribute) (app.db.postgres.AcquisitionTask attribute) (app.db.postgres.Protocol attribute) (app.db.postgres.Result attribute) (app.db.postgres.Task attribute) (app.db.UserSQL attribute)

_broadcast_task_status() (in module app.api.device_websocket) _dag_config (in module orchestrator.repository) _get_dag_config_from_run() (in module orchestrator.sensors) _get_path() (orchestrator.io.base.ScanHubIOManager method) _HEARTBEAT_CHECK_INTERVAL_S (in module app.api.device_websocket) _HEARTBEAT_TIMEOUT_S (in module app.api.device_websocket) _log (in module orchestrator.notifier) _pick_result_type() (in module app.api.device_websocket) _resolve_dicom_path() (in module app.api.result_api) _resolve_mrd_path() (in module app.api.result_api) _SSE_TERMINAL_STATUSES (in module app.api.device_websocket) _stream_to_file() (in module app.api.device_websocket) _submit_reconstruction_job() (in module app.api.device_websocket)

A

access_token (app.db.UserSQL attribute) acquisition_data_asset() (in module orchestrator.assets.acquisition_data) acquisition_data_op() (in module orchestrator.jobs.acquisition_data) acquisition_limits (app.db.postgres.AcquisitionTask attribute) acquisition_parameter (app.db.postgres.AcquisitionTask attribute) AcquisitionData (class in orchestrator.assets.acquisition_data) AcquisitionTask (class in app.db.postgres) add_blank_result_db() (in module app.dal.result_dal) add_dicom_result_db() (in module app.dal.result_dal) add_patient() (in module app.api.dal) add_protocol_data() (in module app.dal.protocol_dal) add_task_data() (in module app.dal.task_dal) add_user() (in module app.dal) app module app (in module app.main) app.api module app.api.dal module app.api.db module app.api.device_endpoints module app.api.device_websocket module app.api.exam_requests module app.api.mri_sequence_api module app.api.protocol_api module app.api.result_api module

app.api.routes module app.api.task_api module app.dal module app.dal.protocol_dal module app.dal.result_dal module app.dal.task_dal module app.db module app.db.mongodb module app.db.postgres module app.main module app.tools module app.tools.dicom_provider module app.tools.helper module app.tools.mrd_provider module app.tools.mri_sequence_plot module app.userlogin module assets (in module orchestrator.repository)

B

Base (class in app.db) (class in app.db.postgres) (in module app.api.db)

base_url (orchestrator.notifier.DeviceManagerNotifier attribute) (orchestrator.notifier.ProtocolManagerNotifier attribute) birth_date (app.api.db.Patient attribute) build_index_meta() (in module app.tools.mrd_provider)

C

calibration (app.db.postgres.AcquisitionTask attribute) change_password() (in module app.userlogin) check_no_users() (in module app.userlogin) client (app.db.mongodb.Database attribute) close_mongo_connection() (in module app.db.mongodb) collection (app.db.mongodb.Database attribute) comment (app.api.db.Patient attribute) (app.db.postgres.Protocol attribute) connect_to_mongo() (in module app.db.mongodb) connection_with_valid_id_and_token() (in module app.api.device_websocket) create_blank_result() (in module app.api.exam_requests) (in module app.api.result_api) (orchestrator.notifier.ProtocolManagerNotifier method) create_device() (in module app.api.device_endpoints)

create_dicom_result() (in module app.api.result_api) create_first_user() (in module app.userlogin) create_mri_sequence() (in module app.api.mri_sequence_api) create_patient() (in module app.api.routes) create_protocol() (in module app.api.protocol_api) create_protocol_from_template() (in module app.api.protocol_api) create_task() (in module app.api.task_api) create_task_from_template() (in module app.api.task_api) create_user() (in module app.userlogin) create_user_internal() (in module app.userlogin) CreateDicomResult (class in app.api.result_api) creator (app.db.postgres.Protocol attribute) (app.db.postgres.Task attribute) custom_http_exception_handler() (in module app.main)

D

dag_config (orchestrator.io.base.ScanHubIOManager attribute) DAG_CONFIG_KEY (in module orchestrator) DAGConfiguration (class in orchestrator.utils.dag_config) DAGSTER_GRAPHQL_URL (in module app.api.device_websocket) DATA_LAKE_DIR (in module app.api.device_websocket) (in module app.tools.dicom_provider) (in module app.tools.mrd_provider) (in module orchestrator.repository) DATA_LAKE_KEY (in module orchestrator) Database (class in app.db.mongodb) DataLakeResource (class in orchestrator.resources) datetime_created (app.api.db.Patient attribute) (app.db.postgres.Protocol attribute) (app.db.postgres.Result attribute) (app.db.postgres.Task attribute) datetime_updated (app.api.db.Patient attribute) (app.db.postgres.Protocol attribute) (app.db.postgres.Task attribute) db (in module app.db.mongodb) defs (in module orchestrator.repository) delete_blank_result() (in module app.api.exam_requests) delete_device() (in module app.api.device_endpoints) delete_mri_sequence_endpoint() (in module app.api.mri_sequence_api) delete_patient() (in module app.api.dal) (in module app.api.routes) delete_protocol_data() (in module app.dal.protocol_dal)

delete_result() (in module app.api.result_api) delete_result_db() (in module app.dal.result_dal) delete_task() (in module app.api.task_api) delete_task_data() (in module app.dal.task_dal) delete_user_data() (in module app.dal) description (app.db.postgres.Protocol attribute) (app.db.postgres.Task attribute) destination (app.db.postgres.Task attribute) Device (in module app.db.postgres) device_id (app.db.postgres.AcquisitionTask attribute) (orchestrator.assets.acquisition_data.AcquisitionData attribute) device_last_seen (in module app.api.device_websocket) DEVICE_MANAGER_URI (in module orchestrator.repository) DEVICE_NOTIFIER_KEY (in module orchestrator) device_parameter (orchestrator.assets.acquisition_data.AcquisitionData attribute) DeviceManagerNotifier (class in orchestrator.notifier) dicom_input (in module orchestrator.assets.dicom_input) DICOM_IO_KEY (in module orchestrator) DicomIOManager (class in orchestrator.io.dicom_io_manager) dict_id_websocket (in module app.api.device_websocket) directory (app.api.result_api.CreateDicomResult attribute) (app.db.postgres.Result attribute) download_mrd() (in module app.api.result_api) dump_to_path() (orchestrator.io.base.ScanHubIOManager method) (orchestrator.io.dicom_io_manager.DicomIOManager method) (orchestrator.io.idata_io_manager.IDataIOManager method)

E

email (app.db.UserSQL attribute)

F

files (app.api.result_api.CreateDicomResult attribute) (app.db.postgres.Result attribute)

find_mrd_file() (in module app.tools.mrd_provider) first_name (app.api.db.Patient attribute) (app.db.UserSQL attribute)

G

generate_plotly_figure() (in module app.tools.mri_sequence_plot) get_all_mri_sequences() (in module app.api.mri_sequence_api) get_all_patient_protocols() (in module app.api.protocol_api) get_all_patients() (in module app.api.dal) get_all_protocol_data() (in module app.dal.protocol_dal) get_all_protocol_tasks() (in module app.api.task_api) get_all_protocol_template_data() (in module app.dal.protocol_dal) get_all_protocol_templates() (in module app.api.protocol_api) get_all_results_db() (in module app.dal.result_dal) get_all_task_data() (in module app.dal.task_dal) get_all_task_results() (in module app.api.result_api) get_all_task_template_data() (in module app.dal.task_dal) get_all_task_templates() (in module app.api.task_api) get_all_users() (in module app.dal) get_current_user() (in module app.userlogin) get_current_user_admin() (in module app.userlogin) get_device() (in module app.api.device_endpoints) get_device_parameter() (orchestrator.resources.DataLakeResource method) get_devices() (in module app.api.device_endpoints) get_dicom() (in module app.api.result_api) get_meta() (in module app.api.result_api) get_mongo_database() (in module app.db.mongodb) get_mrd_binary() (in module app.api.result_api) get_mrd_path() (orchestrator.resources.DataLakeResource method)

get_mri_sequence_by_id() (in module app.api.mri_sequence_api) get_mri_sequence_file_by_id() (in module app.api.mri_sequence_api) get_mri_sequence_header_file_by_id() (in module app.api.mri_sequence_api) get_p10_dicom_bytes() (in module app.tools.dicom_provider) get_patient() (in module app.api.dal) (in module app.api.routes) get_patient_list() (in module app.api.routes) get_patient_out() (in module app.api.routes) get_protocol() (in module app.api.protocol_api) get_protocol_data() (in module app.dal.protocol_dal) get_protocol_out_model() (in module app.tools.helper) get_result() (in module app.api.exam_requests) (in module app.api.result_api) get_result_db() (in module app.dal.result_dal) get_sequence() (in module app.api.exam_requests) get_sequence_plot() (in module app.tools.mri_sequence_plot) get_task() (in module app.api.exam_requests) (in module app.api.task_api) get_task_data() (in module app.dal.task_dal) get_task_out() (in module app.tools.helper) get_user_data() (in module app.dal) get_user_from_token() (in module app.dal) get_user_list() (in module app.userlogin) get_user_out() (in module app.userlogin)

H

handle_file_transfer() (in module app.api.device_websocket) handle_output() (orchestrator.io.base.ScanHubIOManager method)

handle_register() (in module app.api.device_websocket) handle_status_update() (in module app.api.device_websocket) height (app.api.db.Patient attribute)

I

id (app.db.postgres.AcquisitionTask attribute) (app.db.postgres.Protocol attribute) (app.db.postgres.Result attribute) (app.db.postgres.Task attribute) IDATA_IO_KEY (in module orchestrator) IDataIOManager (class in orchestrator.io.idata_io_manager) image_smoothing() (in module orchestrator.assets.image_processing)

indication (app.db.postgres.Protocol attribute) init_db() (in module app.api.db) (in module app.db) (in module app.db.postgres) is_template (app.db.postgres.Protocol attribute) (app.db.postgres.Task attribute) issuer (app.api.db.Patient attribute)

J

jobs (in module orchestrator.repository)

L

last_activity_unixtime (app.db.UserSQL attribute) last_login_unixtime (app.db.UserSQL attribute) last_name (app.api.db.Patient attribute) (app.db.UserSQL attribute) load_acquisitions_slices() (in module app.tools.mrd_provider) load_from_files() (orchestrator.io.base.ScanHubIOManager method) (orchestrator.io.dicom_io_manager.DicomIOManager method) (orchestrator.io.idata_io_manager.IDataIOManager method) load_from_path() (orchestrator.io.base.ScanHubIOManager method) (orchestrator.io.dicom_io_manager.DicomIOManager method) (orchestrator.io.idata_io_manager.IDataIOManager method)

load_input() (orchestrator.io.base.ScanHubIOManager method) locate_mrd() (in module app.tools.mrd_provider) LOG_CALL_DELIMITER (in module app.api.device_endpoints) (in module app.api.device_websocket) (in module app.userlogin) login() (in module app.userlogin) loginfromcookie() (in module app.userlogin) logout() (in module app.userlogin)

M

MappedBase (in module app.db.postgres) MAX_INACTIVITY_TIME_SECONDS (in module app.userlogin) MAX_SESSION_LENGTH_SECONDS (in module app.userlogin) message (app.api.device_websocket.TaskEvent attribute) meta (app.api.result_api.CreateDicomResult attribute) (app.db.postgres.Result attribute) module app app.api app.api.dal app.api.db app.api.device_endpoints app.api.device_websocket app.api.exam_requests app.api.mri_sequence_api app.api.protocol_api app.api.result_api app.api.routes app.api.task_api app.dal app.dal.protocol_dal app.dal.result_dal app.dal.task_dal app.db app.db.mongodb app.db.postgres app.main app.tools app.tools.dicom_provider app.tools.helper app.tools.mrd_provider app.tools.mri_sequence_plot app.userlogin orchestrator orchestrator.assets orchestrator.assets.acquisition_data orchestrator.assets.dicom_input orchestrator.assets.image_processing orchestrator.assets.mrpro_direct_reconstruction orchestrator.io orchestrator.io.base orchestrator.io.dicom_io_manager orchestrator.io.idata_io_manager orchestrator.jobs orchestrator.jobs.acquisition_data orchestrator.notifier orchestrator.repository orchestrator.resources orchestrator.sensors orchestrator.utils orchestrator.utils.dag_config orchestrator.utils.snr

monitor_devices() (in module app.api.device_websocket) mrd_path (orchestrator.assets.acquisition_data.AcquisitionData attribute) mri_sequence_form() (in module app.api.mri_sequence_api) mrpro_direct_reconstruction() (in module orchestrator.assets.mrpro_direct_reconstruction)

N

name (app.db.postgres.Protocol attribute) (app.db.postgres.Task attribute) (app.tools.mri_sequence_plot.TraceData attribute)

O

oauth2_scheme (in module app.api.device_endpoints) (in module app.api.device_websocket) (in module app.api.result_api) on_run_canceled() (in module orchestrator.sensors) on_run_failure() (in module orchestrator.sensors) on_run_success() (in module orchestrator.sensors) orchestrator module orchestrator.assets module orchestrator.assets.acquisition_data module orchestrator.assets.dicom_input module orchestrator.assets.image_processing module orchestrator.assets.mrpro_direct_reconstruction module orchestrator.io module orchestrator.io.base module

orchestrator.io.dicom_io_manager module orchestrator.io.idata_io_manager module orchestrator.jobs module orchestrator.jobs.acquisition_data module orchestrator.notifier module orchestrator.repository module orchestrator.resources module orchestrator.sensors module orchestrator.utils module orchestrator.utils.dag_config module orchestrator.utils.snr module ORIGINS (in module app.main)

P

parse_ids() (in module app.tools.mrd_provider) password_hash (app.db.UserSQL attribute) Patient (class in app.api.db) patient_height_cm (app.db.postgres.Protocol attribute) patient_id (app.api.db.Patient attribute) (app.db.postgres.Protocol attribute) patient_weight_kg (app.db.postgres.Protocol attribute) position (app.db.postgres.Task attribute) postgres_db_name_filepath (in module app.api.db) (in module app.db) (in module app.db.postgres) postgres_password_filepath (in module app.api.db) (in module app.db) (in module app.db.postgres) postgres_user (in module app.api.db) (in module app.db) (in module app.db.postgres)

postgres_user_filepath (in module app.api.db) (in module app.db) (in module app.db.postgres) PREFIX_PATIENT_MANAGER (in module app.api.protocol_api) (in module app.api.result_api) progress (app.api.device_websocket.TaskEvent attribute) (app.db.postgres.Task attribute) Protocol (class in app.db.postgres) protocol_delete() (in module app.api.protocol_api) protocol_id (app.db.postgres.Task attribute) (orchestrator.utils.dag_config.DAGConfiguration attribute) PROTOCOL_MANAGER_URI (in module orchestrator.repository) PROTOCOL_NOTIFIER_KEY (in module orchestrator) protocol_router (in module app.api.protocol_api) ProtocolManagerNotifier (class in orchestrator.notifier) provide_p10_dicom() (in module app.tools.dicom_provider) push_task_event() (in module app.api.device_websocket) (orchestrator.notifier.DeviceManagerNotifier method)

R

RANGE_RE (in module app.tools.mrd_provider) readiness() (in module app.main) reorder_tasks() (in module app.api.task_api) reorder_tasks_data() (in module app.dal.task_dal) resolve_dicom_path() (in module app.tools.dicom_provider) resolve_dicom_path_from_db() (in module app.tools.dicom_provider) ressources (in module orchestrator.repository) Result (class in app.db.postgres)

result_router (in module app.api.result_api) RESULT_URI (in module app.api.exam_requests) results (app.db.postgres.Task attribute) role (app.db.UserSQL attribute) router (in module app.api.device_endpoints) (in module app.api.device_websocket) (in module app.api.routes) (in module app.userlogin)

S

salt (app.db.UserSQL attribute) ScanHubIOManager (class in orchestrator.io.base) send_device_parameter_update() (orchestrator.notifier.DeviceManagerNotifier method) send_json() (in module app.api.device_websocket) sensors (in module orchestrator.repository) seq_router (in module app.api.mri_sequence_api) sequence_id (app.db.postgres.AcquisitionTask attribute) SEQUENCE_URI (in module app.api.exam_requests) set_result() (in module app.api.exam_requests) (in module app.api.result_api) (orchestrator.notifier.ProtocolManagerNotifier method)

set_task() (in module app.api.exam_requests) sex (app.api.db.Patient attribute) signal_to_noise_ratio() (in module orchestrator.utils.snr) source (app.api.device_websocket.TaskEvent attribute) startup() (in module app.main) status (app.api.db.Patient attribute) (app.db.postgres.Protocol attribute) (app.db.postgres.Task attribute)

T

Task (class in app.db.postgres) task_dir (orchestrator.utils.dag_config.DAGConfiguration attribute) task_id (app.db.postgres.Result attribute) (orchestrator.utils.dag_config.DAGConfiguration attribute) task_ids (app.api.task_api.TaskReorder attribute) task_router (in module app.api.task_api) task_sse_queues (in module app.api.device_websocket) task_status (app.api.device_websocket.TaskEvent attribute) task_stream() (in module app.api.device_websocket)

task_type (app.db.postgres.Task attribute) TASK_URI (in module app.api.exam_requests) TaskEvent (class in app.api.device_websocket) TaskReorder (class in app.api.task_api) tasks (app.db.postgres.Protocol attribute) timeout (orchestrator.notifier.DeviceManagerNotifier attribute) (orchestrator.notifier.ProtocolManagerNotifier attribute) TraceData (class in app.tools.mri_sequence_plot) trigger_acquisition() (in module app.api.device_websocket) type (app.db.postgres.Result attribute)

U

update() (app.api.db.Patient method) (app.db.postgres.Base method) update_device_parameter() (in module app.api.device_endpoints) update_mri_sequence_endpoint() (in module app.api.mri_sequence_api) update_patient() (in module app.api.dal) (in module app.api.routes) update_protocol() (in module app.api.protocol_api) update_protocol_data() (in module app.dal.protocol_dal) update_result_db() (in module app.dal.result_dal) update_task() (in module app.api.task_api) update_task_data() (in module app.dal.task_dal)

update_task_status() (in module app.api.exam_requests) (in module app.api.task_api) (in module app.dal.task_dal) (orchestrator.notifier.ProtocolManagerNotifier method) update_user() (in module app.userlogin) update_user_data() (in module app.dal) upload_to_xnat() (in module app.api.result_api) user_access_token (orchestrator.utils.dag_config.DAGConfiguration attribute) user_delete() (in module app.userlogin) username (app.db.UserSQL attribute) UserSQL (class in app.db)

V

validation_exception_handler() (in module app.main)

W

websocket_endpoint() (in module app.api.device_websocket)

weight (app.api.db.Patient attribute)

X

x (app.tools.mri_sequence_plot.TraceData attribute)

Y

y (app.tools.mri_sequence_plot.TraceData attribute)