[GitHub] [airflow] TreyYi edited a comment on issue #21982: Python operators are printing more than one task log at a time

[GitBox <gi...@apache.org>]

TreyYi edited a comment on issue #21982:
URL: https://github.com/apache/airflow/issues/21982#issuecomment-1058885476


   @potiuk @rustikk ,
   
   Can I be assigned for this issue? I know what the problem is, but still thinking of how to resolve it.
   
   The problem is that the log is printed whenever "are_dependencies_met" is called.
   
   In `taskinstance.py`, are_dependencies_met is called even if the `verbose_aware_logger("Dependencies all met for %s", self)` line is always not necessary.
   
   ```
   # line 1202~
   if not self.are_dependencies_met(
                   dep_context=non_requeueable_dep_context, session=session, verbose=True
               ):
                   session.commit()
                   return False
   ```
   
   ```
   # line 1230~
   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 "
                       "%s. State set to NONE.",
                       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
   
   ```


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org