Skip to content

Commit

Permalink
Update the repr method
Browse files Browse the repository at this point in the history
  • Loading branch information
ephraimbuddy committed Mar 6, 2025
1 parent 0f2fed5 commit 5403b77
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions airflow/models/taskinstance.py
Original file line number Diff line number Diff line change
Expand Up @@ -3833,12 +3833,10 @@ def __init__(self, content, user_id=None):
self.user_id = user_id

def __repr__(self):
if self.task_instance:
prefix = f"<{self.__class__.__name__}: {self.task_instance.dag_id}.{self.task_instance.task_id} {self.task_instance.run_id}"
if self.task_instance.map_index != -1:
prefix += f" map_index={self.task_instance.map_index}"
return prefix + ">"
return f"<{self.__class__.__name__}: {self.ti_id}>"
prefix = f"<{self.__class__.__name__}: {self.task_instance.dag_id}.{self.task_instance.task_id} {self.task_instance.run_id}"
if self.task_instance.map_index != -1:
prefix += f" map_index={self.task_instance.map_index}"
return prefix + f" TI ID: {self.ti_id}>"


STATICA_HACK = True
Expand Down

0 comments on commit 5403b77

Please sign in to comment.