We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4be562a commit d602373Copy full SHA for d602373
1 file changed
tests/integration/scenarios/out_s3/tests/test_out_s3_001.py
@@ -234,8 +234,13 @@ def test_out_s3_default_retry_exhausted_action_quarantines_file():
234
235
service = Service("out_s3_retry_exhausted_default_quarantine.yaml")
236
service.start()
237
- time.sleep(6)
+ timeout = time.time() + 10
238
+ files = []
239
+ while time.time() < timeout:
240
+ files = [p for p in glob.glob(f"{store_dir}/**", recursive=True) if os.path.isfile(p)]
241
+ if len(files) > 0:
242
+ break
243
+ time.sleep(0.2)
244
service.stop()
245
- files = [p for p in glob.glob(f"{store_dir}/**", recursive=True) if os.path.isfile(p)]
246
assert len(files) > 0
0 commit comments