kopia lustrzana https://github.com/OpenDroneMap/WebODM
14 wiersze
335 B
Python
14 wiersze
335 B
Python
from worker import tasks
|
|
import redis
|
|
from webodm import settings
|
|
|
|
redis_client = redis.Redis().from_url(settings.CELERY_BROKER_URL)
|
|
|
|
for task in tasks.get_pending_tasks():
|
|
msg = "Unlocking {}... ".format(task)
|
|
res = redis_client.delete('task_lock_{}'.format(task.id))
|
|
print(msg + ("OK" if res else "Already unlocked"))
|
|
|
|
|
|
|