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():