diff --git a/ext/scheduler/airflow/dag/template/dag.2.1.py.tmpl b/ext/scheduler/airflow/dag/template/dag.2.1.py.tmpl index 0a439a3000..3320f39f67 100644 --- a/ext/scheduler/airflow/dag/template/dag.2.1.py.tmpl +++ b/ext/scheduler/airflow/dag/template/dag.2.1.py.tmpl @@ -189,7 +189,7 @@ init_container_{{$hookName}} = k8s.V1Container( image_pull_policy=IMAGE_PULL_POLICY, env=init_env_vars + [ k8s.V1EnvVar(name="INSTANCE_TYPE", value='{{$.ExecutorHook}}'), - k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$hookName}}'), + k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$t.Name}}'), ], security_context=k8s.V1PodSecurityContext(run_as_user=0), volume_mounts=asset_volume_mounts, diff --git a/ext/scheduler/airflow/dag/template/dag.2.4.py.tmpl b/ext/scheduler/airflow/dag/template/dag.2.4.py.tmpl index 0a439a3000..3320f39f67 100644 --- a/ext/scheduler/airflow/dag/template/dag.2.4.py.tmpl +++ b/ext/scheduler/airflow/dag/template/dag.2.4.py.tmpl @@ -189,7 +189,7 @@ init_container_{{$hookName}} = k8s.V1Container( image_pull_policy=IMAGE_PULL_POLICY, env=init_env_vars + [ k8s.V1EnvVar(name="INSTANCE_TYPE", value='{{$.ExecutorHook}}'), - k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$hookName}}'), + k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$t.Name}}'), ], security_context=k8s.V1PodSecurityContext(run_as_user=0), volume_mounts=asset_volume_mounts, diff --git a/ext/scheduler/airflow/dag/template/dag.2.6.py.tmpl b/ext/scheduler/airflow/dag/template/dag.2.6.py.tmpl index 59dedcc4ee..ab68ebd2c9 100644 --- a/ext/scheduler/airflow/dag/template/dag.2.6.py.tmpl +++ b/ext/scheduler/airflow/dag/template/dag.2.6.py.tmpl @@ -189,7 +189,7 @@ init_container_{{$hookName}} = k8s.V1Container( image_pull_policy=IMAGE_PULL_POLICY, env=init_env_vars + [ k8s.V1EnvVar(name="INSTANCE_TYPE", value='{{$.ExecutorHook}}'), - k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$hookName}}'), + k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$t.Name}}'), ], security_context=k8s.V1PodSecurityContext(run_as_user=0), volume_mounts=asset_volume_mounts, diff --git a/ext/scheduler/airflow/dag/template/dag.2.9.py.tmpl b/ext/scheduler/airflow/dag/template/dag.2.9.py.tmpl index 81598d660a..7148108bd2 100644 --- a/ext/scheduler/airflow/dag/template/dag.2.9.py.tmpl +++ b/ext/scheduler/airflow/dag/template/dag.2.9.py.tmpl @@ -189,7 +189,7 @@ init_container_{{$hookName}} = k8s.V1Container( image_pull_policy=IMAGE_PULL_POLICY, env=init_env_vars + [ k8s.V1EnvVar(name="INSTANCE_TYPE", value='{{$.ExecutorHook}}'), - k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$hookName}}'), + k8s.V1EnvVar(name="INSTANCE_NAME", value='{{$t.Name}}'), ], security_context=k8s.V1PodSecurityContext(run_as_user=0), volume_mounts=asset_volume_mounts,