Changeset View
Changeset View
Standalone View
Standalone View
swh/deposit/cli/admin.py
| Show First 20 Lines • Show All 225 Lines • ▼ Show 20 Lines | def adm_deposit_reschedule(ctx, deposit_id): | ||||
| """ | """ | ||||
| # to avoid loading too early django namespaces | # to avoid loading too early django namespaces | ||||
| from datetime import datetime | from datetime import datetime | ||||
| from swh.deposit.models import Deposit | from swh.deposit.models import Deposit | ||||
| from swh.deposit.config import ( | from swh.deposit.config import ( | ||||
| DEPOSIT_STATUS_LOAD_SUCCESS, | DEPOSIT_STATUS_LOAD_SUCCESS, | ||||
| DEPOSIT_STATUS_LOAD_FAILURE, | DEPOSIT_STATUS_LOAD_FAILURE, | ||||
| DEPOSIT_STATUS_VERIFIED, | DEPOSIT_STATUS_VERIFIED, | ||||
| SWHDefaultConfig, | APIConfig, | ||||
| ) | ) | ||||
| try: | try: | ||||
| deposit = Deposit.objects.get(pk=deposit_id) | deposit = Deposit.objects.get(pk=deposit_id) | ||||
| except Deposit.DoesNotExist: | except Deposit.DoesNotExist: | ||||
| click.echo("Deposit %s does not exist." % deposit_id) | click.echo("Deposit %s does not exist." % deposit_id) | ||||
| ctx.exit(1) | ctx.exit(1) | ||||
| Show All 20 Lines | def adm_deposit_reschedule(ctx, deposit_id): | ||||
| # Reset the deposit's state | # Reset the deposit's state | ||||
| deposit.swh_id = None | deposit.swh_id = None | ||||
| deposit.swh_id_context = None | deposit.swh_id_context = None | ||||
| deposit.status = DEPOSIT_STATUS_VERIFIED | deposit.status = DEPOSIT_STATUS_VERIFIED | ||||
| deposit.save() | deposit.save() | ||||
| # Trigger back the deposit | # Trigger back the deposit | ||||
| scheduler = SWHDefaultConfig().scheduler | scheduler = APIConfig().scheduler | ||||
| scheduler.set_status_tasks( | scheduler.set_status_tasks( | ||||
| [task_id], status="next_run_not_scheduled", next_run=datetime.now() | [task_id], status="next_run_not_scheduled", next_run=datetime.now() | ||||
| ) | ) | ||||