1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
from __future__ import annotations
from time import time
import pytest
from watchdog.utils.delayed_queue import DelayedQueue
@pytest.mark.flaky(max_runs=5, min_passes=1)
def test_delayed_get():
q = DelayedQueue[str](2)
q.put("", delay=True)
inserted = time()
q.get()
elapsed = time() - inserted
# 2.10 instead of 2.05 for slow macOS slaves on Travis
assert 2.10 > elapsed > 1.99
@pytest.mark.flaky(max_runs=5, min_passes=1)
def test_nondelayed_get():
q = DelayedQueue[str](2)
q.put("")
inserted = time()
q.get()
elapsed = time() - inserted
# Far less than 1 second
assert elapsed < 1
|
