add reindex task lock, implement add to running queue
This commit is contained in:
parent
c25af5cfaa
commit
3b3d151ec3
|
@ -77,6 +77,7 @@ class StartupCheck:
|
|||
"downloading",
|
||||
"dl_queue",
|
||||
"dl_queue_id",
|
||||
"reindex",
|
||||
"rescan",
|
||||
"run_backup",
|
||||
]
|
||||
|
|
|
@ -137,10 +137,23 @@ def check_reindex(data=False, extract_videos=False):
|
|||
"""run the reindex main command"""
|
||||
if data:
|
||||
ReindexManual(extract_videos=extract_videos).extract_data(data)
|
||||
else:
|
||||
ReindexOutdated().add_outdated()
|
||||
|
||||
Reindex().reindex_all()
|
||||
have_lock = False
|
||||
reindex_lock = RedisArchivist().get_lock("reindex")
|
||||
|
||||
try:
|
||||
have_lock = reindex_lock.acquire(blocking=False)
|
||||
if have_lock:
|
||||
if not data:
|
||||
ReindexOutdated().add_outdated()
|
||||
|
||||
Reindex().reindex_all()
|
||||
else:
|
||||
print("Did not acquire reindex lock.")
|
||||
|
||||
finally:
|
||||
if have_lock:
|
||||
reindex_lock.release()
|
||||
|
||||
|
||||
@shared_task
|
||||
|
|
Loading…
Reference in New Issue