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 <[email protected]>
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(
