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,