yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-11-08 15:30:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(ci): add back optional static sleep for tests (#8258)

Browse Source
This commit is contained in:
Aseem Bansal 2023-06-19 13:47:44 +05:30 committed by GitHub
parent a5ee1cae62
commit 3de94c5223
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
smoke-test/tests/consistency_utils.py
View File

@ -1,8 +1,15 @@
import time import time
import os
import subprocess import subprocess
_ELASTIC_BUFFER_WRITES_TIME_IN_SEC: int = 1 _ELASTIC_BUFFER_WRITES_TIME_IN_SEC: int = 1
USE_STATIC_SLEEP: bool = bool(os.getenv("USE_STATIC_SLEEP", False))
ELASTICSEARCH_REFRESH_INTERVAL_SECONDS: int = int(os.getenv("ELASTICSEARCH_REFRESH_INTERVAL_SECONDS", 5))
def wait_for_writes_to_sync(max_timeout_in_sec: int = 120) -> None: def wait_for_writes_to_sync(max_timeout_in_sec: int = 120) -> None:
if USE_STATIC_SLEEP:
time.sleep(ELASTICSEARCH_REFRESH_INTERVAL_SECONDS)
return
start_time = time.time() start_time = time.time()
# get offsets # get offsets
lag_zero = False lag_zero = False