summaryrefslogtreecommitdiffstats
path: root/src/orchestrator/orchestrator.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/orchestrator/orchestrator.rs')
-rw-r--r--src/orchestrator/orchestrator.rs26
1 files changed, 9 insertions, 17 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs
index 0132e08..e511669 100644
--- a/src/orchestrator/orchestrator.rs
+++ b/src/orchestrator/orchestrator.rs
@@ -1,31 +1,23 @@
use std::path::PathBuf;
-use std::sync::RwLock;
use std::sync::Arc;
-use std::collections::BTreeMap;
+use std::sync::RwLock;
-use anyhow::anyhow;
-use anyhow::Error;
use anyhow::Context;
+use anyhow::Error;
use anyhow::Result;
-use typed_builder::TypedBuilder;
+use anyhow::anyhow;
use diesel::PgConnection;
-use tokio::sync::mpsc::UnboundedReceiver;
-use tokio::sync::mpsc::UnboundedSender;
-use resiter::AndThen;
+use typed_builder::TypedBuilder;
+use crate::db::models::Submit;
use crate::endpoint::EndpointConfiguration;
use crate::endpoint::EndpointScheduler;
-use crate::job::JobSet;
-use crate::job::RunnableJob;
-use crate::log::LogItem;
-use crate::filestore::StagingStore;
+use crate::filestore::MergedStores;
use crate::filestore::ReleaseStore;
+use crate::filestore::StagingStore;
+use crate::job::JobSet;
use crate::log::FileLogSinkFactory;
-use crate::log::LogSink;
-use crate::db::models::Submit;
-use crate::db::models::EnvVar;
-use crate::job::JobResource;
-use crate::filestore::MergedStores;
+use crate::log::LogItem;
use crate::util::progress::ProgressBars;
pub struct Orchestrator {