We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f7050fb commit 4ac9a6dCopy full SHA for 4ac9a6d
airflow/contrib/kubernetes/worker_configuration.py
@@ -153,6 +153,13 @@ def _get_environment(self):
153
self.kube_config.git_subpath # dags
154
)
155
env['AIRFLOW__CORE__DAGS_FOLDER'] = dag_volume_mount_path
156
+
157
+ # TODO This change can be submitted into the apache as well.
158
+ # Set the scheduler env into the worker pod.
159
+ os_env = os.environ
160
+ os_env.update(env)
161
+ env = os_env
162
163
return env
164
165
def _get_configmaps(self):
0 commit comments