Changeset View
Changeset View
Standalone View
Standalone View
swh/deposit/tests/api/test_deposit_schedule.py
| Show First 20 Lines • Show All 53 Lines • ▼ Show 20 Lines | ): | ||||
| timestamp_after_call = now() | timestamp_after_call = now() | ||||
| assert response.status_code == status.HTTP_201_CREATED | assert response.status_code == status.HTTP_201_CREATED | ||||
| response_content = parse_xml(BytesIO(response.content)) | response_content = parse_xml(BytesIO(response.content)) | ||||
| actual_state = response_content["swh:deposit_status"] | actual_state = response_content["swh:deposit_status"] | ||||
| assert actual_state == DEPOSIT_STATUS_DEPOSITED | assert actual_state == DEPOSIT_STATUS_DEPOSITED | ||||
| deposit_id = response_content["deposit_id"] | deposit_id = response_content["swh:deposit_id"] | ||||
| tasks = swh_scheduler.grab_ready_tasks("check-deposit") | tasks = swh_scheduler.grab_ready_tasks("check-deposit") | ||||
| assert len(tasks) == 1 | assert len(tasks) == 1 | ||||
| task = tasks[0] | task = tasks[0] | ||||
| assert timestamp_before_call <= task.pop("next_run") <= timestamp_after_call | assert timestamp_before_call <= task.pop("next_run") <= timestamp_after_call | ||||
| assert task["arguments"] == { | assert task["arguments"] == { | ||||
| "args": [], | "args": [], | ||||
| "kwargs": {"collection": "test", "deposit_id": int(deposit_id),}, | "kwargs": {"collection": "test", "deposit_id": int(deposit_id),}, | ||||
| } | } | ||||
| assert task["policy"] == "oneshot" | assert task["policy"] == "oneshot" | ||||
| assert task["type"] == "check-deposit" | assert task["type"] == "check-deposit" | ||||
| assert task["retries_left"] == 3 | assert task["retries_left"] == 3 | ||||