@@ -15,7 +15,6 @@ async def async_wait_for_file(path, exists: bool = True) -> None:
15
15
while True :
16
16
await asyncio .sleep (0.1 )
17
17
if os .path .exists (path ) == exists :
18
- await asyncio .sleep (0.1 ) # Wait for signal
19
18
return
20
19
21
20
@@ -51,11 +50,13 @@ async def test_file_runner_async(tmp_path):
51
50
with open (req_file , 'w' ) as f :
52
51
json .dump ({'input' : {'i' : 1 , 's' : 'bar' }}, f )
53
52
await async_wait_for_file (req_file , exists = False )
53
+ await asyncio .sleep (0.2 ) # Extra wait for signal
54
54
assert signals == [
55
55
file_runner .FileRunner .SIG_READY ,
56
56
file_runner .FileRunner .SIG_BUSY ,
57
57
]
58
58
await async_wait_for_file (resp_file )
59
+ await asyncio .sleep (0.2 ) # Extra wait for signal
59
60
assert signals == [
60
61
file_runner .FileRunner .SIG_READY ,
61
62
file_runner .FileRunner .SIG_BUSY ,
@@ -98,12 +99,14 @@ async def test_file_runner_async_concurrency(tmp_path):
98
99
json .dump ({'input' : {'i' : 1 , 's' : 'baz' }}, f )
99
100
await async_wait_for_file (req_file_a , exists = False )
100
101
await async_wait_for_file (req_file_b , exists = False )
102
+ await asyncio .sleep (0.2 ) # Extra wait for signal
101
103
assert signals == [
102
104
file_runner .FileRunner .SIG_READY ,
103
105
file_runner .FileRunner .SIG_BUSY ,
104
106
]
105
107
await async_wait_for_file (resp_file_a )
106
108
await async_wait_for_file (resp_file_b )
109
+ await asyncio .sleep (0.2 ) # Extra wait for signal
107
110
assert signals == [
108
111
file_runner .FileRunner .SIG_READY ,
109
112
file_runner .FileRunner .SIG_BUSY ,
@@ -150,6 +153,7 @@ async def test_file_runner_async_cancel(tmp_path):
150
153
with open (req_file , 'w' ) as f :
151
154
json .dump ({'input' : {'i' : 60 , 's' : 'bar' }}, f )
152
155
await async_wait_for_file (req_file , exists = False )
156
+ await asyncio .sleep (0.2 ) # Extra wait for signal
153
157
assert signals == [
154
158
file_runner .FileRunner .SIG_READY ,
155
159
file_runner .FileRunner .SIG_BUSY ,
@@ -159,6 +163,7 @@ async def test_file_runner_async_cancel(tmp_path):
159
163
await async_wait_for_file (cancel_file , exists = False )
160
164
161
165
await async_wait_for_file (resp_file )
166
+ await asyncio .sleep (0.2 ) # Extra wait for signal
162
167
assert signals == [
163
168
file_runner .FileRunner .SIG_READY ,
164
169
file_runner .FileRunner .SIG_BUSY ,
0 commit comments