From b2f7680e1d67e057aad64abd77da5c0a420737b0 Mon Sep 17 00:00:00 2001 From: Tomas Kracmar Date: Sun, 5 Oct 2025 14:53:49 +0200 Subject: [PATCH] Tooling update --- scripts/podx-tools.sh | 24 +++++++++++++++++++++--- 1 file changed, 21 insertions(+), 3 deletions(-) diff --git a/scripts/podx-tools.sh b/scripts/podx-tools.sh index fdb9c7e..0047641 100755 --- a/scripts/podx-tools.sh +++ b/scripts/podx-tools.sh @@ -891,7 +891,13 @@ url = sys.argv[1] if len(sys.argv)>1 else 'redis://redis:6379/0' conn = Redis.from_url(url) def clear(name): q = Queue(name, connection=conn) - regs = [FailedJobRegistry(q), StartedJobRegistry(q), DeferredJobRegistry(q), FinishedJobRegistry(q), ScheduledJobRegistry(q)] + regs = [ + FailedJobRegistry(name=q.name, connection=conn), + StartedJobRegistry(name=q.name, connection=conn), + DeferredJobRegistry(name=q.name, connection=conn), + FinishedJobRegistry(name=q.name, connection=conn), + ScheduledJobRegistry(name=q.name, connection=conn), + ] for reg in regs: try: for jid in reg.get_job_ids(): @@ -921,7 +927,13 @@ url = sys.argv[1] if len(sys.argv)>1 else 'redis://redis:6379/0' conn = Redis.from_url(url) def clear(name): q = Queue(name, connection=conn) - regs = [FailedJobRegistry(q), StartedJobRegistry(q), DeferredJobRegistry(q), FinishedJobRegistry(q), ScheduledJobRegistry(q)] + regs = [ + FailedJobRegistry(name=q.name, connection=conn), + StartedJobRegistry(name=q.name, connection=conn), + DeferredJobRegistry(name=q.name, connection=conn), + FinishedJobRegistry(name=q.name, connection=conn), + ScheduledJobRegistry(name=q.name, connection=conn), + ] for reg in regs: try: for jid in reg.get_job_ids(): @@ -951,7 +963,13 @@ url = sys.argv[1] if len(sys.argv)>1 else 'redis://redis:6379/0' conn = Redis.from_url(url) def clear(name): q = Queue(name, connection=conn) - regs = [FailedJobRegistry(q), StartedJobRegistry(q), DeferredJobRegistry(q), FinishedJobRegistry(q), ScheduledJobRegistry(q)] + regs = [ + FailedJobRegistry(name=q.name, connection=conn), + StartedJobRegistry(name=q.name, connection=conn), + DeferredJobRegistry(name=q.name, connection=conn), + FinishedJobRegistry(name=q.name, connection=conn), + ScheduledJobRegistry(name=q.name, connection=conn), + ] for reg in regs: try: for jid in reg.get_job_ids():