We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f3724f3 commit 7bf79ebCopy full SHA for 7bf79eb
python/activator/activator.py
@@ -573,11 +573,11 @@ def process_visit(expected_visit: FannedOutVisit):
573
574
_log.debug("Waiting for snaps...")
575
start = time.time()
576
- while len(expid_set) < expected_snaps and time.time() - start < timeout:
+ while len(expid_set) < expected_snaps and time_since(start) < timeout:
577
if startup_response:
578
response = startup_response
579
else:
580
- time_remaining = max(0.0, timeout - (time.time() - start))
+ time_remaining = max(0.0, timeout - time_since(start))
581
response = consumer.consume(num_messages=1, timeout=time_remaining + 1.0)
582
end = time.time()
583
messages = _filter_messages(response)
0 commit comments