Skip to content

Commit

Permalink
Fix PR comments
Browse files Browse the repository at this point in the history
  • Loading branch information
sunank200 committed Jun 7, 2024
1 parent 31c52f6 commit 1f22222
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions airflow/dag_processing/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -679,7 +679,7 @@ def _fetch_callbacks(self, max_callbacks: int, session: Session = NEW_SESSION):
@retry_db_transaction
def _fetch_callbacks_with_retries(self, max_callbacks: int, session: Session):
"""Fetch callbacks from database and add them to the internal queue for execution."""
self.log.warning("Fetching callbacks from the database.")
self.log.debug("Fetching callbacks from the database.")
with prohibit_commit(session) as guard:
query = select(DbCallbackRequest)
if self.standalone_dag_processor:
Expand Down Expand Up @@ -764,7 +764,7 @@ def _refresh_dag_dir(self) -> bool:
self.set_file_paths(self._file_paths)

try:
self.log.warning("Removing old import errors")
self.log.debug("Removing old import errors")
DagFileProcessorManager.clear_nonexistent_import_errors(
file_paths=self._file_paths, processor_subdir=self.get_dag_directory()
)
Expand Down
2 changes: 1 addition & 1 deletion airflow/dag_processing/processor.py
Original file line number Diff line number Diff line change
Expand Up @@ -784,7 +784,7 @@ def _execute_task_callbacks(
# the callback

if not is_remote and not request.is_failure_callback:
self.log.warning("not failure callback: %s", request)
self.log.debug("not failure callback: %s", request)
return

simple_ti = request.simple_task_instance
Expand Down

0 comments on commit 1f22222

Please sign in to comment.