Add passing of additional env

This patch adds the code to pass the additional environment to the
container job.

Signed-off-by: Matthias Beyer <mail@beyermatthias.de>

1 files changed, 2 insertions, 1 deletions

diff --git a/src/endpoint/configured.rs b/src/endpoint/configured.rs
index f9a04d5..9e9171b 100644
--- a/src/endpoint/configured.rs
+++ b/src/endpoint/configured.rs
@@ -176,7 +176,7 @@ impl Endpoint {
             .map(|_| ())
     }
 
-    pub async fn run_job(&self, job: RunnableJob, logsink: UnboundedSender<LogItem>, staging: Arc<RwLock<StagingStore>>) -> RResult<(Vec<PathBuf>, ContainerHash, Script), ContainerError> {
+    pub async fn run_job(&self, job: RunnableJob, logsink: UnboundedSender<LogItem>, staging: Arc<RwLock<StagingStore>>, additional_env: Vec<(String, String)>) -> RResult<(Vec<PathBuf>, ContainerHash, Script), ContainerError> {
         use crate::log::buffer_stream_to_line_stream;
         use tokio::stream::StreamExt;
         use futures::FutureExt;
@@ -185,6 +185,7 @@ impl Endpoint {
             let envs = job.environment()
                 .into_iter()
                 .chain(job.package_environment().into_iter())
+                .chain(additional_env.into_iter())
                 .map(|(k, v)| format!("{}={}", k, v))
                 .collect::<Vec<_>>();
             trace!("Job resources: Environment variables = {:?}", envs);