Skip to content

Commit 8372246

Browse files
authored
Merge pull request #119 from qiboteam/feature/bulk-delete
Bulk delete
2 parents f4e06bb + 25dae6f commit 8372246

File tree

2 files changed

+19
-0
lines changed

2 files changed

+19
-0
lines changed

src/qibo_client/qibo_client.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,3 +258,13 @@ def delete_job(self, pid: str):
258258
"""
259259
job = QiboJob(base_url=self.base_url, headers=self.headers, pid=pid)
260260
return job.delete()
261+
262+
def delete_all_jobs(self) -> list[str]:
263+
"""Removes all jobs from the web server."""
264+
url = self.base_url + "/api/jobs/bulk_delete/"
265+
response = QiboApiRequest.delete(
266+
url, headers=self.headers, timeout=constants.TIMEOUT
267+
)
268+
deleted_jobs = response.json()["deleted"]
269+
logger.info("Deleted %s jobs", len(deleted_jobs))
270+
return deleted_jobs

tests/test_qibo_client.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -350,3 +350,12 @@ def test_delete_job(self):
350350

351351
response = self.obj.delete_job(FAKE_PID)
352352
assert response == response_json["detail"]
353+
354+
@responses.activate
355+
def test_delete_all_jobs(self):
356+
endpoint = FAKE_URL + "/api/jobs/bulk_delete/"
357+
response_json = {"deleted": ["jobPid1", "jobPid2"]}
358+
responses.add(responses.DELETE, endpoint, status=200, json=response_json)
359+
360+
response = self.obj.delete_all_jobs()
361+
assert response == response_json["deleted"]

0 commit comments

Comments
 (0)