@@ -45,7 +45,7 @@ def test_get_tasks_with_all_plural_parameters(client, empty_index):
45
45
{"indexUids" : [common .INDEX_UID ], "statuses" : ["succeeded" ], "types" : ["indexCreation" ]}
46
46
)
47
47
assert isinstance (tasks , dict )
48
- assert len (tasks ["results" ]) > 1
48
+ assert len (tasks ["results" ]) >= 1
49
49
50
50
51
51
def test_get_tasks_with_date_parameters (client , empty_index ):
@@ -136,28 +136,34 @@ def test_cancel_every_task(client):
136
136
def test_delete_tasks_by_uid (client , empty_index , small_movies ):
137
137
"""Tests getting a task of an inexistent operation."""
138
138
index = empty_index ()
139
- task = index .add_documents (small_movies )
140
- task_deleted = client .delete_tasks ({"uids" : task .task_uid })
139
+ task_addition = index .add_documents (small_movies )
140
+ task_deleted = client .delete_tasks ({"uids" : task_addition .task_uid })
141
141
client .wait_for_task (task_deleted .task_uid )
142
142
with pytest .raises (Exception ):
143
- client .get_task (task .task_uid )
143
+ client .get_task (task_addition .task_uid )
144
+ task = client .get_task (task_deleted .task_uid )
144
145
145
146
assert isinstance (task_deleted , TaskInfo )
146
147
assert task_deleted .task_uid is not None
147
148
assert task_deleted .index_uid is None
148
- assert task_deleted .status == "enqueued" or "processing" or "succeeded"
149
149
assert task_deleted .type == "taskDeletion"
150
+ assert "uids" in task ["details" ]["originalFilter" ]
151
+ assert f"uids={ task_addition .task_uid } " in task ["details" ]["originalFilter" ]
150
152
151
153
152
154
def test_delete_all_tasks (client ):
153
155
tasks_before = client .get_tasks ()
154
156
task = client .delete_tasks ({"statuses" : ["succeeded" , "failed" , "canceled" ]})
157
+ client .wait_for_task (task .task_uid )
155
158
tasks_after = client .get_tasks ()
156
159
157
160
assert isinstance (task , TaskInfo )
158
161
assert task .task_uid is not None
159
162
assert task .index_uid is None
160
- assert task .status == "enqueued" or "processing" or "succeeded"
161
163
assert task .type == "taskDeletion"
162
164
assert len (tasks_after ["results" ]) == 1
163
165
assert len (tasks_before ["results" ]) == len (tasks_after ["results" ])
166
+ assert (
167
+ "statuses=succeeded%2Cfailed%2Ccanceled"
168
+ in tasks_after ["results" ][0 ]["details" ]["originalFilter" ]
169
+ )
0 commit comments