diff options
author | Matthias Beyer <mail@beyermatthias.de> | 2020-11-11 17:04:11 +0100 |
---|---|---|
committer | Matthias Beyer <mail@beyermatthias.de> | 2020-11-11 17:05:39 +0100 |
commit | f1626ac35ef0c8359e4a342a564a3365d96bce1c (patch) | |
tree | 3e291e3902cbe0c11bb41eb842fd2a6558430074 /src/orchestrator/orchestrator.rs | |
parent | dbb931d96ce53ee8f94ac8604985e4408576974e (diff) |
Copy package source to container before running build
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
Diffstat (limited to 'src/orchestrator/orchestrator.rs')
-rw-r--r-- | src/orchestrator/orchestrator.rs | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs index 4b195a6..9c8ca9b 100644 --- a/src/orchestrator/orchestrator.rs +++ b/src/orchestrator/orchestrator.rs @@ -18,6 +18,7 @@ use crate::filestore::StagingStore; use crate::job::JobSet; use crate::log::FileLogSinkFactory; use crate::log::LogItem; +use crate::source::SourceCache; use crate::util::progress::ProgressBars; pub struct Orchestrator { @@ -25,6 +26,7 @@ pub struct Orchestrator { scheduler: EndpointScheduler, staging_store: Arc<RwLock<StagingStore>>, release_store: Arc<RwLock<ReleaseStore>>, + source_cache: SourceCache, jobsets: Vec<JobSet>, database: PgConnection, file_log_sink_factory: Option<FileLogSinkFactory>, @@ -36,6 +38,7 @@ pub struct OrchestratorSetup { endpoint_config: Vec<EndpointConfiguration>, staging_store: Arc<RwLock<StagingStore>>, release_store: Arc<RwLock<ReleaseStore>>, + source_cache: SourceCache, jobsets: Vec<JobSet>, database: PgConnection, submit: Submit, @@ -51,6 +54,7 @@ impl OrchestratorSetup { scheduler: scheduler, staging_store: self.staging_store, release_store: self.release_store, + source_cache: self.source_cache, jobsets: self.jobsets, database: self.database, file_log_sink_factory: self.file_log_sink_factory, @@ -82,7 +86,7 @@ impl Orchestrator { let (results, logs) = { // run the jobs in the set let unordered_results = futures::stream::FuturesUnordered::new(); let unordered_receivers = futures::stream::FuturesUnordered::new(); - for runnable in jobset.into_runables(&merged_store) { + for runnable in jobset.into_runables(&merged_store, &self.source_cache) { let runnable = runnable?; let job_id = runnable.uuid().clone(); trace!("Runnable {} for package {}", job_id, runnable.package().name()); |