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 d6c79ce340 Remove tenancity on KPO logs inner func consume_logs
(#35504)
d6c79ce340 is described below
commit d6c79ce340dd4cd088edfa92ed052d643ae3587d
Author: Daniel Standish <15932138+dstand...@users.noreply.github.com>
AuthorDate: Tue Nov 7 10:41:25 2023 -0800
Remove tenancity on KPO logs inner func consume_logs (#35504)
There are many overlapping layers and strategies of retrying in this area
of code. It appears this particular layer may be unnecessary. See discussion
starting at
https://github.com/apache/airflow/pull/31622#issuecomment-1793124398.
---
airflow/providers/cncf/kubernetes/utils/pod_manager.py | 5 -----
1 file changed, 5 deletions(-)
diff --git a/airflow/providers/cncf/kubernetes/utils/pod_manager.py
b/airflow/providers/cncf/kubernetes/utils/pod_manager.py
index 75ff82fc2f..856f5fa19b 100644
--- a/airflow/providers/cncf/kubernetes/utils/pod_manager.py
+++ b/airflow/providers/cncf/kubernetes/utils/pod_manager.py
@@ -385,11 +385,6 @@ class PodManager(LoggingMixin):
:meta private:
"""
- @tenacity.retry(
- retry=tenacity.retry_if_exception_type(ApiException),
- stop=tenacity.stop_after_attempt(10),
- wait=tenacity.wait_fixed(1),
- )
def consume_logs(
*,
since_time: DateTime | None = None,
