diff --git a/airflow/utils/log/task_context_logger.py b/airflow/utils/log/task_context_logger.py
index 07a5ed74e8be7..61cecfd92f5bb 100644
--- a/airflow/utils/log/task_context_logger.py
+++ b/airflow/utils/log/task_context_logger.py
@@ -101,7 +101,7 @@ def _log(self, level: int, msg: str, *args, ti: TaskInstance):
             task_handler.set_context(ti, identifier=self.component_name)
             if hasattr(task_handler, "mark_end_on_close"):
                 task_handler.mark_end_on_close = False
-            filename, lineno, func, stackinfo = logger.findCaller()
+            filename, lineno, func, stackinfo = logger.findCaller(stacklevel=3)
             record = logging.LogRecord(
                 self.component_name, level, filename, lineno, msg, args, None, func=func
             )