This is an automated email from the ASF dual-hosted git repository.
jedcunningham 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 3a8b427658 Increase log reader stream loop sleep duration to 1 second
(#34789)
3a8b427658 is described below
commit 3a8b427658959b1cb14ae26317600ae4cc44665c
Author: Daniel Standish <[email protected]>
AuthorDate: Thu Oct 5 15:16:18 2023 -0700
Increase log reader stream loop sleep duration to 1 second (#34789)
One second is plenty fast. And it only sleeps if it doesn't find on first
try. Nicer to your ES cluster etc.
---
airflow/utils/log/log_reader.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/utils/log/log_reader.py b/airflow/utils/log/log_reader.py
index 589281fd55..ad61a13908 100644
--- a/airflow/utils/log/log_reader.py
+++ b/airflow/utils/log/log_reader.py
@@ -36,7 +36,7 @@ if TYPE_CHECKING:
class TaskLogReader:
"""Task log reader."""
- STREAM_LOOP_SLEEP_SECONDS = 0.5
+ STREAM_LOOP_SLEEP_SECONDS = 1
"""Time to sleep between loops while waiting for more logs"""
def read_log_chunks(
