(airflow) branch main updated: Set parallelism log messages to warning level for better visiblity (#39298)

[rnhttr]

This is an automated email from the ASF dual-hosted git repository.

rnhttr 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 ad5921837e Set parallelism log messages to warning level for better 
visiblity (#39298)
ad5921837e is described below

commit ad5921837ea2a52142ff3d3d2ce37e6170f99842
Author: Bas Harenslak <ba...@users.noreply.github.com>
AuthorDate: Wed Jul 17 16:51:49 2024 +0200

    Set parallelism log messages to warning level for better visiblity (#39298)
    
    * Set log messages related to parallelism to warning level for better 
visibility
    
    * Set a few logging statements back to info
---
 airflow/executors/base_executor.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/airflow/executors/base_executor.py 
b/airflow/executors/base_executor.py
index 153f0d3360..1a13877f88 100644
--- a/airflow/executors/base_executor.py
+++ b/airflow/executors/base_executor.py
@@ -223,7 +223,10 @@ class BaseExecutor(LoggingMixin):
 
         self.log.debug("%s running task instances", num_running_tasks)
         self.log.debug("%s in queue", num_queued_tasks)
-        self.log.debug("%s open slots", open_slots)
+        if open_slots == 0:
+            self.log.info("Executor parallelism limit reached. 0 open slots.")
+        else:
+            self.log.debug("%s open slots", open_slots)
 
         Stats.gauge(
             "executor.open_slots", value=open_slots, tags={"status": "open", 
"name": self.__class__.__name__}