Skip to content
This repository has been archived by the owner on Sep 20, 2024. It is now read-only.

[QUAD] Ftrack Sync: Add task data to mongodb #6340

Open
wants to merge 1 commit into
base: develop
Choose a base branch
from
Open
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -540,7 +540,6 @@ def filter_updated(self, updates):
ent_info["keys"] = ["name"]
ent_info["changes"] = {"name": changes.pop("name")}
filtered_updates[ftrack_id] = ent_info
continue

for _key in self.ignore_keys:
if _key in changed_keys:
Expand Down Expand Up @@ -662,6 +661,10 @@ def launch(self, session, event):

elif "typeid" in changes or "name" in changes:
self.modified_tasks_ftrackids.add(ent_info["parentId"])
elif action == "update":
self.modified_tasks_ftrackids.add(ent_info["parentId"])
found_actions.add(action)
entities_by_action[action][ftrack_id] = ent_info
continue

if action == "move":
Expand Down Expand Up @@ -1927,6 +1930,8 @@ def process_updated(self):
cust_attrs_by_obj_id[obj_id][key] = cust_attr

for ftrack_id, ent_info in ent_infos.items():
if ent_info["entity_type"] == "Task":
ftrack_id = ent_info["parentId"]
mongo_id = ftrack_mongo_mapping[ftrack_id]
entType = ent_info["entityType"]
ent_path = self.get_ent_path(ftrack_id)
Expand Down Expand Up @@ -2440,7 +2445,8 @@ def process_task_updates(self):
continue

tasks_per_ftrack_id[ftrack_id][task_entity["name"]] = {
"type": task_type["name"]
"type": task_type["name"],
"custom_attributes": dict(task_entity["custom_attributes"])
}

# find avalon entity by parentId
Expand Down
Loading