Index A | B | C | D | E | F | G | H | I | J | L | M | N | O | P | Q | R | S | T | U | V A abbreviation_map (aind_data_transfer_service.configs.platforms_v1.Platform attribute) acq_datetime (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) admin() (in module aind_data_transfer_service.server) aind_data_transfer_service module aind_data_transfer_service.configs module aind_data_transfer_service.configs.csv_handler module aind_data_transfer_service.configs.job_upload_template module aind_data_transfer_service.configs.platforms_v1 module aind_data_transfer_service.log_handler module aind_data_transfer_service.models module aind_data_transfer_service.models.core module aind_data_transfer_service.models.internal module aind_data_transfer_service.server module AirflowDagRun (class in aind_data_transfer_service.models.internal) AirflowDagRunsRequestParameters (class in aind_data_transfer_service.models.internal) AirflowDagRunsResponse (class in aind_data_transfer_service.models.internal) AirflowTaskInstance (class in aind_data_transfer_service.models.internal) AirflowTaskInstanceLogsRequestParameters (class in aind_data_transfer_service.models.internal) AirflowTaskInstancesRequestParameters (class in aind_data_transfer_service.models.internal) AirflowTaskInstancesResponse (class in aind_data_transfer_service.models.internal) ALL (aind_data_transfer_service.configs.platforms_v1.Platform attribute) auth() (in module aind_data_transfer_service.server) B BEHAVIOR (aind_data_transfer_service.configs.platforms_v1.Platform attribute) C cancel_job() (in module aind_data_transfer_service.server) check_duplicate_upload_jobs() (aind_data_transfer_service.models.core.SubmitJobRequestV2 method) command_script (aind_data_transfer_service.models.core.Task attribute) comment (aind_data_transfer_service.models.internal.JobStatus attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) conf (aind_data_transfer_service.models.internal.AirflowDagRun attribute) CONFOCAL (aind_data_transfer_service.configs.platforms_v1.Platform attribute) create_excel_sheet_filestream() (aind_data_transfer_service.configs.job_upload_template.JobUploadTemplate class method) create_nested_dict() (in module aind_data_transfer_service.configs.csv_handler) CustomJsonFormatter (class in aind_data_transfer_service) D dag_id (aind_data_transfer_service.models.core.SubmitJobRequestV2 attribute) (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstancesRequestParameters attribute) (aind_data_transfer_service.models.internal.JobStatus attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) dag_ids (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) dag_run_id (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstancesRequestParameters attribute) dag_runs (aind_data_transfer_service.models.internal.AirflowDagRunsResponse attribute) data_interval_end (aind_data_transfer_service.models.internal.AirflowDagRun attribute) data_interval_start (aind_data_transfer_service.models.internal.AirflowDagRun attribute) download_job_template() (in module aind_data_transfer_service.server) duration (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) E ECEPHYS (aind_data_transfer_service.configs.platforms_v1.Platform attribute) email_notification_types (aind_data_transfer_service.models.core.SubmitJobRequestV2 attribute) (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) end_date (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) end_time (aind_data_transfer_service.models.internal.JobStatus attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) EventType (class in aind_data_transfer_service.log_handler) EXASPIM (aind_data_transfer_service.configs.platforms_v1.Platform attribute) execution_date (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) execution_date_gte (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) execution_date_lte (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) executor_config (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) external_trigger (aind_data_transfer_service.models.internal.AirflowDagRun attribute) F FILE_NAME (aind_data_transfer_service.configs.job_upload_template.JobUploadTemplate attribute) FIP (aind_data_transfer_service.configs.platforms_v1.Platform attribute) formatTime() (aind_data_transfer_service.CustomJsonFormatter method) from_abbreviation() (aind_data_transfer_service.configs.platforms_v1.Platform class method) from_airflow_dag_run() (aind_data_transfer_service.models.internal.JobStatus class method) from_airflow_task_instance() (aind_data_transfer_service.models.internal.JobTasks class method) from_aws_describe_parameter() (aind_data_transfer_service.models.internal.JobParamInfo class method) from_query_params() (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters class method) (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters class method) (aind_data_transfer_service.models.internal.AirflowTaskInstancesRequestParameters class method) full_content (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters attribute) G get_airflow_jobs() (in module aind_data_transfer_service.server) get_job_status_list() (in module aind_data_transfer_service.server) get_job_types() (in module aind_data_transfer_service.server) get_parameter_infos() (in module aind_data_transfer_service.server) get_parameter_name() (aind_data_transfer_service.models.internal.JobParamInfo static method) get_parameter_prefix() (aind_data_transfer_service.models.internal.JobParamInfo static method) get_parameter_regex() (aind_data_transfer_service.models.internal.JobParamInfo static method) get_parameter_v2() (in module aind_data_transfer_service.server) get_parameter_value() (in module aind_data_transfer_service.server) get_project_names() (in module aind_data_transfer_service.server) get_task_logs() (in module aind_data_transfer_service.server) get_tasks_list() (in module aind_data_transfer_service.server) H HCR (aind_data_transfer_service.configs.platforms_v1.Platform attribute) hostname (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) HSFP (aind_data_transfer_service.configs.platforms_v1.Platform attribute) I image (aind_data_transfer_service.models.core.Task attribute) image_resources (aind_data_transfer_service.models.core.Task attribute) image_version (aind_data_transfer_service.models.core.Task attribute) index() (in module aind_data_transfer_service.server) ISI (aind_data_transfer_service.configs.platforms_v1.Platform attribute) J jinja_dict (aind_data_transfer_service.models.internal.JobStatus property) job_id (aind_data_transfer_service.models.internal.JobStatus attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) job_params() (in module aind_data_transfer_service.server) job_settings (aind_data_transfer_service.models.core.Task attribute) job_state (aind_data_transfer_service.models.internal.JobStatus attribute) job_tasks_table() (in module aind_data_transfer_service.server) job_type (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) (aind_data_transfer_service.models.internal.JobParamInfo attribute) (aind_data_transfer_service.models.internal.JobStatus attribute) JobParamInfo (class in aind_data_transfer_service.models.internal) jobs() (in module aind_data_transfer_service.server) JobStatus (class in aind_data_transfer_service.models.internal) JobTasks (class in aind_data_transfer_service.models.internal) JobUploadTemplate (class in aind_data_transfer_service.configs.job_upload_template) L last_modified (aind_data_transfer_service.models.internal.JobParamInfo attribute) last_scheduling_decision (aind_data_transfer_service.models.internal.AirflowDagRun attribute) list_parameters_v2() (in module aind_data_transfer_service.server) log_submit_job_request() (in module aind_data_transfer_service.log_handler) logical_date (aind_data_transfer_service.models.internal.AirflowDagRun attribute) login() (in module aind_data_transfer_service.server) logout() (in module aind_data_transfer_service.server) M map_csv_row_to_job() (in module aind_data_transfer_service.configs.csv_handler) map_index (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) max_tries (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) MERFISH (aind_data_transfer_service.configs.platforms_v1.Platform attribute) MESOSPIM (aind_data_transfer_service.configs.platforms_v1.Platform attribute) modalities (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) modality (aind_data_transfer_service.models.internal.JobParamInfo attribute) model_config (aind_data_transfer_service.configs.job_upload_template.JobUploadTemplate attribute) (aind_data_transfer_service.models.core.SubmitJobRequestV2 attribute) (aind_data_transfer_service.models.core.Task attribute) (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) (aind_data_transfer_service.models.internal.AirflowDagRunsResponse attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstancesRequestParameters attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstancesResponse attribute) (aind_data_transfer_service.models.internal.JobParamInfo attribute) (aind_data_transfer_service.models.internal.JobStatus attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) module aind_data_transfer_service aind_data_transfer_service.configs aind_data_transfer_service.configs.csv_handler aind_data_transfer_service.configs.job_upload_template aind_data_transfer_service.configs.platforms_v1 aind_data_transfer_service.log_handler aind_data_transfer_service.models aind_data_transfer_service.models.core aind_data_transfer_service.models.internal aind_data_transfer_service.server MOTOR_OBSERVATORY (aind_data_transfer_service.configs.platforms_v1.Platform attribute) MRI (aind_data_transfer_service.configs.platforms_v1.Platform attribute) MULTIPLANE_OPHYS (aind_data_transfer_service.configs.platforms_v1.Platform attribute) N name (aind_data_transfer_service.models.internal.JobParamInfo attribute) (aind_data_transfer_service.models.internal.JobStatus attribute) nested_update() (in module aind_data_transfer_service.configs.csv_handler) note (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) O ONE_OF (aind_data_transfer_service.configs.platforms_v1.Platform attribute) operator (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) order_by (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) P page_limit (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) page_offset (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) pid (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) platform (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) Platform (class in aind_data_transfer_service.configs.platforms_v1) pool (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) pool_slots (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) priority_weight (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) project_name (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) propagate_email_settings() (aind_data_transfer_service.models.core.SubmitJobRequestV2 method) put_parameter() (in module aind_data_transfer_service.server) put_parameter_value() (in module aind_data_transfer_service.server) Q queue (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) queued_when (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) R rendered_fields (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) run_type (aind_data_transfer_service.models.internal.AirflowDagRun attribute) S s3_bucket (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) s3_prefix (aind_data_transfer_service.models.core.UploadJobConfigsV2 property) set_oauth() (in module aind_data_transfer_service.server) SINGLE_PLANE_OPHYS (aind_data_transfer_service.configs.platforms_v1.Platform attribute) skip_task (aind_data_transfer_service.models.core.Task attribute) sla_miss (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) SLAP2 (aind_data_transfer_service.configs.platforms_v1.Platform attribute) SMARTSPIM (aind_data_transfer_service.configs.platforms_v1.Platform attribute) STAGE_COMPLETE (aind_data_transfer_service.log_handler.EventType attribute) STAGE_FAILURE (aind_data_transfer_service.log_handler.EventType attribute) STAGE_START (aind_data_transfer_service.log_handler.EventType attribute) start_date (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) start_time (aind_data_transfer_service.models.internal.JobStatus attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) state (aind_data_transfer_service.models.internal.AirflowDagRun attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) states (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters attribute) subject_id (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) submit_jobs_v2() (in module aind_data_transfer_service.server) submit_time (aind_data_transfer_service.models.internal.JobStatus attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) SubmitJobRequestV2 (class in aind_data_transfer_service.models.core) T Task (class in aind_data_transfer_service.models.core) task_id (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters attribute) (aind_data_transfer_service.models.internal.JobParamInfo attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) task_instances (aind_data_transfer_service.models.internal.AirflowTaskInstancesResponse attribute) task_logs() (in module aind_data_transfer_service.server) task_state (aind_data_transfer_service.models.internal.JobTasks attribute) tasks (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) total_entries (aind_data_transfer_service.models.internal.AirflowDagRunsResponse attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstancesResponse attribute) trigger (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) triggerer_job (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) try_number (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) (aind_data_transfer_service.models.internal.AirflowTaskInstanceLogsRequestParameters attribute) (aind_data_transfer_service.models.internal.JobTasks attribute) U unixname (aind_data_transfer_service.models.internal.AirflowTaskInstance attribute) upload_jobs (aind_data_transfer_service.models.core.SubmitJobRequestV2 attribute) UploadJobConfigsV2 (class in aind_data_transfer_service.models.core) user_email (aind_data_transfer_service.models.core.SubmitJobRequestV2 attribute) (aind_data_transfer_service.models.core.UploadJobConfigsV2 attribute) V validate_csv() (in module aind_data_transfer_service.server) validate_json_serializable() (aind_data_transfer_service.models.core.Task class method) validate_json_v2() (in module aind_data_transfer_service.server) validate_min_execution_date() (aind_data_transfer_service.models.internal.AirflowDagRunsRequestParameters class method) validate_platform() (aind_data_transfer_service.models.core.UploadJobConfigsV2 class method) validate_tasks() (aind_data_transfer_service.models.core.UploadJobConfigsV2 class method) validate_with_context() (aind_data_transfer_service.models.core.UploadJobConfigsV2 class method) validation_context() (in module aind_data_transfer_service.models.core) version (aind_data_transfer_service.models.internal.JobParamInfo attribute)