Frame13/ayon-core
1
0
Fork 1
mirror of https://github.com/ynput/ayon-core.git synced 2025-12-25 21:32:15 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

OP-2427 - reprocess all failed records for batch only once

Browse source
This commit is contained in:
Petr Kalis 2022-01-19 17:38:58 +01:00
parent dd1c0b18df
commit 769dc41ebb
1 changed files with 19 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

28
openpype/hosts/webpublisher/webserver_service/webserver_cli.py
View file

@ -126,7 +126,11 @@ def reprocess_failed(upload_dir, webserver_url):
dbcon = mongo_client[database_name]["webpublishes"]
results = dbcon.find({"status": "reprocess"})
reprocessed_batches = set()
for batch in results:
if batch["batch_id"] in reprocessed_batches:
continue
batch_url = os.path.join(upload_dir,
batch["batch_id"],
"manifest.json")
@ -150,18 +154,24 @@ def reprocess_failed(upload_dir, webserver_url):
with open(batch_url) as f:
data = json.loads(f.read())
dbcon.update_many(
{
"batch_id": batch["batch_id"],
"status": {"$in": ["error", "reprocess"]}
},
{
"$set": {
"finish_date": datetime.now(),
"status": "sent_for_reprocessing",
"progress": 100
}
}
)
try:
r = requests.post(server_url, json=data)
log.info("response{}".format(r))
except Exception:
log.info("exception", exc_info=True)
dbcon.update_one(
{"_id": batch["_id"]},
{"$set":
{
"finish_date": datetime.now(),
"status": "sent_for_reprocessing",
"progress": 100
}}
)
reprocessed_batches.add(batch["batch_id"])