summaryrefslogtreecommitdiffstats
path: root/src/orchestrator
diff options
context:
space:
mode:
authorMatthias Beyer <mail@beyermatthias.de>2020-12-03 08:17:16 +0100
committerMatthias Beyer <mail@beyermatthias.de>2020-12-03 08:17:16 +0100
commitfcdda0b9999fbb5f796ad67f8a23ffdfe2093b2b (patch)
treeb3508fe7adcbe50c80c7ba70336d2eb1ad51e012 /src/orchestrator
parent7040473abebe31a5ce22ab7b509b48276c920987 (diff)
Remove unused member: Orchestrator::database
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
Diffstat (limited to 'src/orchestrator')
-rw-r--r--src/orchestrator/orchestrator.rs4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs
index fd2d02c..65bc6c9 100644
--- a/src/orchestrator/orchestrator.rs
+++ b/src/orchestrator/orchestrator.rs
@@ -32,7 +32,6 @@ pub struct Orchestrator {
release_store: Arc<RwLock<ReleaseStore>>,
source_cache: SourceCache,
jobsets: Vec<JobSet>,
- database: Arc<PgConnection>,
}
#[derive(TypedBuilder)]
@@ -52,7 +51,7 @@ pub struct OrchestratorSetup {
impl OrchestratorSetup {
pub async fn setup(self) -> Result<Orchestrator> {
let db = Arc::new(self.database);
- let scheduler = EndpointScheduler::setup(self.endpoint_config, self.staging_store.clone(), db.clone(), self.progress_generator, self.submit.clone(), self.log_dir, self.additional_env).await?;
+ let scheduler = EndpointScheduler::setup(self.endpoint_config, self.staging_store.clone(), db, self.progress_generator, self.submit.clone(), self.log_dir, self.additional_env).await?;
Ok(Orchestrator {
scheduler: scheduler,
@@ -60,7 +59,6 @@ impl OrchestratorSetup {
release_store: self.release_store,
source_cache: self.source_cache,
jobsets: self.jobsets,
- database: db,
})
}
}