minor fix

airflowdags/csv_ingestion_all_steps.py

@@ -50,8 +50,6 @@ env_vars = {| ENV_VARS or {} |}
 if data_service_to_use:
     env_vars["data_service_to_use"] = data_service_to_use
 
-env_vars["docker_image"] = DOCKER_IMAGE
-
 operator_kwargs = {| K8S_POD_OPERATOR_KWARGS or {} |}
 
 with DAG(DAG_NAME, default_args=default_args) as dag:
@@ -66,7 +64,7 @@ with DAG(DAG_NAME, default_args=default_args) as dag:
         env_vars=env_vars,
         arguments=[dumps(params)],
         is_delete_operator_pod=True,
-        image=env_vars["docker_image"],
+        image=DOCKER_IMAGE,
         **operator_kwargs)
 
     update_status_finished = UpdateStatusOperator(