[airflow] branch main updated: Add dep context description for better log message (#28875)

[dstandish]

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 1ca94ee6ba Add dep context description for better log message (#28875)
1ca94ee6ba is described below

commit 1ca94ee6ba767ed6851858db24319aa1008562eb
Author: Daniel Standish <15932138+dstand...@users.noreply.github.com>
AuthorDate: Wed Jan 11 23:56:49 2023 -0800

    Add dep context description for better log message (#28875)
    
    Otherwise, it appears that there is a duplicate log record.
---
 airflow/models/taskinstance.py | 4 +++-
 airflow/ti_deps/dep_context.py | 1 +
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py
index fcead1fc7e..fe382155ec 100644
--- a/airflow/models/taskinstance.py
+++ b/airflow/models/taskinstance.py
@@ -1090,7 +1090,7 @@ class TaskInstance(Base, LoggingMixin):
         if failed:
             return False
 
-        verbose_aware_logger("Dependencies all met for %s", self)
+        verbose_aware_logger("Dependencies all met for dep_context=%s ti=%s", 
dep_context.description, self)
         return True
 
     @provide_session
@@ -1242,6 +1242,7 @@ class TaskInstance(Base, LoggingMixin):
                 ignore_depends_on_past=ignore_depends_on_past,
                 
wait_for_past_depends_before_skipping=wait_for_past_depends_before_skipping,
                 ignore_task_deps=ignore_task_deps,
+                description="non-requeueable deps",
             )
             if not self.are_dependencies_met(
                 dep_context=non_requeueable_dep_context, session=session, 
verbose=True
@@ -1271,6 +1272,7 @@ class TaskInstance(Base, LoggingMixin):
                 
wait_for_past_depends_before_skipping=wait_for_past_depends_before_skipping,
                 ignore_task_deps=ignore_task_deps,
                 ignore_ti_state=ignore_ti_state,
+                description="requeueable deps",
             )
             if not self.are_dependencies_met(dep_context=dep_context, 
session=session, verbose=True):
                 self.state = State.NONE
diff --git a/airflow/ti_deps/dep_context.py b/airflow/ti_deps/dep_context.py
index 6f2d603509..fbdb81355a 100644
--- a/airflow/ti_deps/dep_context.py
+++ b/airflow/ti_deps/dep_context.py
@@ -77,6 +77,7 @@ class DepContext:
     ignore_ti_state: bool = False
     ignore_unmapped_tasks: bool = False
     finished_tis: list[TaskInstance] | None = None
+    description: str | None = None
 
     have_changed_ti_states: bool = False
     """Have any of the TIs state's been changed as a result of evaluating 
dependencies"""