This is an automated email from the ASF dual-hosted git repository.
dstandish pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new dd39f84653 Simplify trigger name expression (#34356)
dd39f84653 is described below
commit dd39f846537e1a3558a596866424ca4304cb2438
Author: Daniel Standish <[email protected]>
AuthorDate: Wed Sep 13 22:22:55 2023 -0700
Simplify trigger name expression (#34356)
Just more readable.
---
airflow/jobs/triggerer_job_runner.py | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
diff --git a/airflow/jobs/triggerer_job_runner.py
b/airflow/jobs/triggerer_job_runner.py
index 9262a53f30..34a271c3ac 100644
--- a/airflow/jobs/triggerer_job_runner.py
+++ b/airflow/jobs/triggerer_job_runner.py
@@ -492,15 +492,11 @@ class TriggerRunner(threading.Thread, LoggingMixin):
while self.to_create:
trigger_id, trigger_instance = self.to_create.popleft()
if trigger_id not in self.triggers:
- task_instance: TaskInstance = trigger_instance.task_instance
- dag_id = task_instance.dag_id
- run_id = task_instance.run_id
- task_id = task_instance.task_id
- map_index = task_instance.map_index
- try_number = task_instance.try_number
+ ti: TaskInstance = trigger_instance.task_instance
self.triggers[trigger_id] = {
"task": asyncio.create_task(self.run_trigger(trigger_id,
trigger_instance)),
- "name":
f"{dag_id}/{run_id}/{task_id}/{map_index}/{try_number} (ID {trigger_id})",
+ "name":
f"{ti.dag_id}/{ti.run_id}/{ti.task_id}/{ti.map_index}/{ti.try_number} "
+ f"(ID {trigger_id})",
"events": 0,
}
else:
