29
29
from .conftest import AsyncClientFixture
30
30
31
31
32
- @pytest .mark .asyncio
33
32
async def test_entire_workflow_update (
34
33
async_client : AsyncClientFixture ,
35
34
data_store_mgr : DataStoreMgr ,
@@ -61,7 +60,6 @@ async def test_entire_workflow_update(
61
60
assert entire_workflow .workflow .id == w_id_data ['workflow' ].id
62
61
63
62
64
- @pytest .mark .asyncio
65
63
async def test_entire_workflow_update_ignores_timeout_message (
66
64
async_client : AsyncClientFixture ,
67
65
data_store_mgr : DataStoreMgr
@@ -89,7 +87,6 @@ async def test_entire_workflow_update_ignores_timeout_message(
89
87
assert w_id not in data_store_mgr .data
90
88
91
89
92
- @pytest .mark .asyncio
93
90
async def test_entire_workflow_update_gather_error (
94
91
async_client : AsyncClientFixture ,
95
92
data_store_mgr : DataStoreMgr ,
@@ -128,7 +125,6 @@ async def test_entire_workflow_update_gather_error(
128
125
assert caplog .records [0 ].exc_info [0 ] == error_type
129
126
130
127
131
- @pytest .mark .asyncio
132
128
async def test_register_workflow (
133
129
data_store_mgr : DataStoreMgr
134
130
):
@@ -141,7 +137,6 @@ async def test_register_workflow(
141
137
assert w_id in data_store_mgr .delta_queues
142
138
143
139
144
- @pytest .mark .asyncio
145
140
async def test_update_contact_no_contact_data (
146
141
data_store_mgr : DataStoreMgr
147
142
):
@@ -154,7 +149,6 @@ async def test_update_contact_no_contact_data(
154
149
assert api_version == data_store_mgr .data [w_id ]['workflow' ].api_version
155
150
156
151
157
- @pytest .mark .asyncio
158
152
async def test_update_contact_with_contact_data (
159
153
data_store_mgr : DataStoreMgr
160
154
):
@@ -174,7 +168,6 @@ async def test_update_contact_with_contact_data(
174
168
assert api_version == data_store_mgr .data [w_id ]['workflow' ].api_version
175
169
176
170
177
- @pytest .mark .asyncio
178
171
async def test_disconnect_workflow (
179
172
data_store_mgr : DataStoreMgr
180
173
):
@@ -197,7 +190,6 @@ async def test_disconnect_workflow(
197
190
assert data_store_mgr .data [w_id ]['workflow' ].api_version == 0
198
191
199
192
200
- @pytest .mark .asyncio
201
193
async def test_workflow_connect_fail (
202
194
data_store_mgr : DataStoreMgr ,
203
195
port_range ,
0 commit comments