Frame13/ayon-core
1
0
Fork 1
mirror of https://github.com/ynput/ayon-core.git synced 2026-01-02 00:44:52 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Preparation to delay Version document write to database closer to representation write

Browse source
This commit is contained in:
Roy Nieterau 2022-03-24 14:25:15 +01:00
parent 5b1f6eb30c
commit 3369c15bdf
1 changed files with 15 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

24
openpype/plugins/publish/integrate_new.py
View file

@ -466,15 +466,16 @@ class IntegrateAssetNew(pyblish.api.InstancePlugin):
'name': version_number
})
bulk_writes = []
if existing_version is None:
self.log.debug("Creating new version ...")
version_id = io.insert_one(version).inserted_id
version["_id"] = ObjectId()
bulk_writes.append(InsertOne(version))
else:
self.log.debug("Updating existing version ...")
# Check if instance have set `append` mode which cause that
# only replicated representations are set to archive
append_repres = instance.data.get("append", False)
bulk_writes = []
# Update version data
version_id = existing_version['_id']
@ -484,6 +485,12 @@ class IntegrateAssetNew(pyblish.api.InstancePlugin):
'$set': version
}))
# Instead of directly writing and querying we reproduce what
# the resulting version would look like so we can hold off making
# changes to the database to avoid the need for 'rollback'
version = copy.deepcopy(version)
version["_id"] = existing_version["_id"]
# Find representations of existing version and archive them
repres = instance.data.get("representations", [])
new_repre_names_low = [_repre["name"].lower() for _repre in repres]
@ -507,13 +514,12 @@ class IntegrateAssetNew(pyblish.api.InstancePlugin):
repre["type"] = "archived_representation"
bulk_writes.append(InsertOne(repre))
# bulk updates
if bulk_writes:
io._database[io.Session["AVALON_PROJECT"]].bulk_write(
bulk_writes
)
version = io.find_one({"_id": version_id})
# bulk updates
# todo: Try to avoid writing already until after we've prepared
# representations to allow easier rollback?
io._database[io.Session["AVALON_PROJECT"]].bulk_write(
bulk_writes
)
self.log.info("Registered version: v{0:03d}".format(version["name"]))