(airflow) branch main updated: Fix test_remote_logging_s3 test when contents written to s3 is zero (#58492)

[am...@apache.org]

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

amoghdesai 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 a32f94e7a00 Fix test_remote_logging_s3 test when contents written to s3 is zero (#58492)
a32f94e7a00 is described below

commit a32f94e7a00d036665eb02f328351e1bb86704ef
Author: LIU ZHE YOU <68...@users.noreply.github.com>
AuthorDate: Thu Nov 20 01:05:10 2025 +0800

    Fix test_remote_logging_s3 test when contents written to s3 is zero (#58492)
---
 .../tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py b/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py
index 15c45fbc5b8..25feb196e6c 100644
--- a/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py
+++ b/airflow-e2e-tests/tests/airflow_e2e_tests/remote_log_tests/test_remote_logging.py
@@ -74,10 +74,11 @@ class TestRemoteLogging:
             print(f"Expected at least {self.task_count} log files, found {len(contents)}. Retrying...")
             time.sleep(self.retry_interval_in_seconds)
 
-        if len(response["Contents"]) < self.task_count:
+        if len(contents) < self.task_count:
             pytest.fail(
                 f"Expected at least {self.task_count} log files in S3 bucket {bucket_name}, "
-                f"but found {len(response['Contents'])} objects: {[obj.get('Key') for obj in response.get('Contents', [])]}"
+                f"but found {len(contents)} objects: {[obj.get('Key') for obj in contents]}. \n"
+                f"List Objects Response: {response}"
             )
 
         task_logs = self.airflow_client.get_task_logs(