Itmens/lib.itmens
Itmens/lib.itmens
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

requeue failed job

Browse source
This commit is contained in:
Your Name 2023-12-27 16:22:46 -05:00 • committed by Henri Dickson
parent 06e606d672
commit 10a88174d1
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
common/management/commands/jobs.py
View file

@ -12,10 +12,19 @@ class Command(BaseCommand):
help = "Show jobs in queue"
def add_arguments(self, parser):
parser.add_argument("--retry", action="append")
parser.add_argument("--delete", action="append")
parser.add_argument("--list", action="store_true")
def handle(self, *args, **options):
if options["retry"]:
queue = Queue(connection=django_rq.get_connection("fetch"))
registry = queue.failed_job_registry
for job_id in options["retry"]:
# registry.requeue(job_id)
job = Job.fetch(job_id, connection=django_rq.get_connection("fetch"))
job.requeue()
self.stdout.write(self.style.SUCCESS(f"Retrying {job_id}"))
if options["delete"]:
for job_id in options["delete"]:
job = Job.fetch(job_id, connection=django_rq.get_connection("fetch"))