fix dag processor job_runner, add missing job_type

apache · May 10, 2023 · 1cfdc41 · 1cfdc41
1 parent 89e0c51
commit 1cfdc41
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/airflow/jobs/dag_processor_job_runner.py b/airflow/jobs/dag_processor_job_runner.py
@@ -53,6 +53,7 @@ def __init__(
                 f"The job is already assigned a different job_type: {job.job_type}."
                 f"This is a bug and should be reported."
             )
+        self.job.job_type = self.job_type
         self.processor = processor
         self.processor.heartbeat = lambda: perform_heartbeat(
             job=self.job,