From b82ad7212f35563e79aa18406265580d25ba8201 Mon Sep 17 00:00:00 2001 From: Pat Nadolny Date: Wed, 14 Dec 2022 08:26:38 -0500 Subject: [PATCH] support schedule env vars --- bundle/orchestrate/dags/meltano.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/bundle/orchestrate/dags/meltano.py b/bundle/orchestrate/dags/meltano.py index cb4dc89..6067540 100644 --- a/bundle/orchestrate/dags/meltano.py +++ b/bundle/orchestrate/dags/meltano.py @@ -154,6 +154,8 @@ def _meltano_job_generator(schedules): task_id=task_id, bash_command=f"cd {PROJECT_ROOT}; {MELTANO_BIN} run {run_args}", dag=dag, + env=schedule.get("env", {}), # snag an env from the schedule + append_env=True, # append , don't replace the inherited env ) if previous_task: task.set_upstream(previous_task)