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

added invalidation of instances on instance refresh

Browse source
This commit is contained in:
iLLiCiTiT 2021-08-18 12:01:37 +02:00
parent c7ce6a21fb
commit d972534db6
1 changed files with 44 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

44
openpype/pipeline/create/context.py
View file

@ -491,6 +491,7 @@ class CreateContext:
# Collect instances
host_instances = self.host.list_instances()
instances = []
task_names_by_asset_name = collections.defaultdict(set)
for instance_data in host_instances:
family = instance_data["family"]
# Prepare publish plugins with attribute definitions
@ -503,6 +504,49 @@ class CreateContext:
)
instances.append(instance)
task_name = instance_data.get("task")
asset_name = instance_data.get("asset")
if asset_name and task_name:
task_names_by_asset_name[asset_name].add(task_name)
asset_names = [
asset_name
for asset_name in task_names_by_asset_name.keys()
if asset_name is not None
]
asset_docs = list(self.dbcon.find(
{
"type": "asset",
"name": {"$in": asset_names}
},
{
"name": True,
"data.tasks": True
}
))
task_names_by_asset_name = {}
for asset_doc in asset_docs:
asset_name = asset_doc["name"]
tasks = asset_doc.get("data", {}).get("tasks") or {}
task_names_by_asset_name[asset_name] = set(tasks.keys())
for instance in instances:
if not instance.has_valid_asset or not instance.has_valid_task:
continue
asset_name = instance.data["asset"]
if asset_name not in task_names_by_asset_name:
instance.set_asset_invalid(True)
continue
task_name = instance.data["task"]
if not task_name:
continue
if task_name not in task_names_by_asset_name[asset_name]:
instance.set_task_invalid(True)
self.instances = instances
def _get_publish_plugins_with_attr_for_family(self, family):