File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change 21
21
POSTGRES_DSN = os .environ .get (
22
22
"POSTGRES_DSN" , "postgresql://postgres:password@localhost:15432/postgres"
23
23
) # noqa
24
- LEASE_TIMEOUT = 0.1
24
+ # We set the lease timeout to 2 seconds, because if the database is slow
25
+ # the timeout would be reached while we are still getting the tasks and
26
+ # the tests fail.
27
+ LEASE_TIMEOUT = 2
25
28
26
29
logger = logging .getLogger (__name__ )
27
30
@@ -82,7 +85,7 @@ def test_is_empty(task_queue: TaskQueue):
82
85
83
86
def test_complete (task_queue : TaskQueue ):
84
87
# boring case
85
- task_queue .add ({"foo" : 1 }, LEASE_TIMEOUT + 0.1 , ttl = 1 )
88
+ task_queue .add ({"foo" : 1 }, LEASE_TIMEOUT , ttl = 1 )
86
89
_ , id_ , qname = task_queue .get ()
87
90
assert not task_queue .is_empty ()
88
91
assert qname == "test_queue"
@@ -100,7 +103,7 @@ def test_complete(task_queue: TaskQueue):
100
103
101
104
102
105
def test_expired (task_queue : TaskQueue ):
103
- task_queue .add ({"foo" : 1 }, LEASE_TIMEOUT + 0.1 , ttl = 1 )
106
+ task_queue .add ({"foo" : 1 }, LEASE_TIMEOUT , ttl = 1 )
104
107
task_queue .get ()
105
108
assert not task_queue .is_empty ()
106
109
time .sleep (LEASE_TIMEOUT + 0.1 )
You can’t perform that action at this time.
0 commit comments