This is an automated email from the ASF dual-hosted git repository. pierrejeambrun pushed a commit to branch v2-5-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit c22c42dbd43b0b34b2e42a195e124e8786ceae41 Author: Daniel Standish <[email protected]> AuthorDate: Wed Jan 11 23:40:17 2023 -0800 Remove horizontal lines in TI logs (#28876) These are not helpful and certainly provide no meaningful information. (cherry picked from commit c7f0aca52509a528460bda2c91bce761f09ee92c) --- airflow/models/taskinstance.py | 8 -------- 1 file changed, 8 deletions(-) diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index f237fe35e3..615a98f6cb 100644 --- a/airflow/models/taskinstance.py +++ b/airflow/models/taskinstance.py @@ -1218,9 +1218,6 @@ class TaskInstance(Base, LoggingMixin): if not ignore_all_deps and not ignore_ti_state and self.state == State.SUCCESS: Stats.incr("previously_succeeded", 1, 1) - # TODO: Logging needs cleanup, not clear what is being printed - hr_line_break = "\n" + ("-" * 80) # Line break - if not mark_success: # Firstly find non-runnable and non-requeueable tis. # Since mark_success is not set, we do nothing. @@ -1263,7 +1260,6 @@ class TaskInstance(Base, LoggingMixin): ) if not self.are_dependencies_met(dep_context=dep_context, session=session, verbose=True): self.state = State.NONE - self.log.warning(hr_line_break) self.log.warning( "Rescheduling due to concurrency limits reached " "at task runtime. Attempt %s of " @@ -1271,16 +1267,12 @@ class TaskInstance(Base, LoggingMixin): self.try_number, self.max_tries + 1, ) - self.log.warning(hr_line_break) self.queued_dttm = timezone.utcnow() session.merge(self) session.commit() return False - # print status message - self.log.info(hr_line_break) self.log.info("Starting attempt %s of %s", self.try_number, self.max_tries + 1) - self.log.info(hr_line_break) self._try_number += 1 if not test_mode:
