vibecoding/podx
1
0
Fork 0
Code Issues 4 Pull Requests Actions Packages Projects Releases Wiki Activity

Tooling update

Browse Source
This commit is contained in:
Tomas Kracmar
2025-10-05 14:53:49 +02:00
parent 7455b519c2
commit b2f7680e1d
1 changed files with 21 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
scripts/podx-tools.sh
View File

@@ -891,7 +891,13 @@ url = sys.argv[1] if len(sys.argv)>1 else 'redis://redis:6379/0'
conn = Redis.from_url(url) conn = Redis.from_url(url)
def clear(name): def clear(name):
q = Queue(name, connection=conn) 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: for reg in regs:
try: try:
for jid in reg.get_job_ids(): 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) conn = Redis.from_url(url)
def clear(name): def clear(name):
q = Queue(name, connection=conn) 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: for reg in regs:
try: try:
for jid in reg.get_job_ids(): 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) conn = Redis.from_url(url)
def clear(name): def clear(name):
q = Queue(name, connection=conn) 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: for reg in regs:
try: try:
for jid in reg.get_job_ids(): for jid in reg.get_job_ids():