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

Project creation logs happens outside of write_project_to_op() function

Browse source
This commit is contained in:
Jacob Danell 2023-03-02 12:30:19 +01:00 • committed by Milan Kolar
parent 0beec8c3a7
commit 247778575f
2 changed files with 12 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

12
openpype/modules/kitsu/utils/sync_service.py
View file

@ -129,12 +129,9 @@ class Listener:
"""Create new project into OP DB."""
# Use update process to avoid duplicating code
self._update_project(data)
self._update_project(data, new_project=True)
# Print message
# - Happens in write_project_to_op()
def _update_project(self, data):
def _update_project(self, data, new_project=False):
"""Update project into OP DB."""
# Get project entity
project = gazu.project.get_project(data["project_id"])
@ -147,6 +144,9 @@ class Listener:
data["project_id"])
self.dbcon.bulk_write([update_project])
if new_project:
log.info("Project created: {}".format(project["name"]))
def _delete_project(self, data):
"""Delete project."""
@ -579,7 +579,7 @@ class Listener:
shot=task["entity"]["name"]
)
ent_type=ent_type + " - " if ent_type is not None else ""
ent_type = ent_type + " - " if ent_type is not None else ""
msg = "Task deleted: {proj} - {ent_type}{parent}" \
" - {task}".format(
proj=task["zou"]["project"]["name"],

9
openpype/modules/kitsu/utils/update_op_with_zou.py
View file

@ -291,7 +291,6 @@ def write_project_to_op(project: dict, dbcon: AvalonMongoDB) -> UpdateOne:
project_name = project["name"]
project_dict = get_project(project_name)
if not project_dict:
log.info("Project created: {}".format(project_name))
project_dict = create_project(project_name, project_name)
# Project data and tasks
@ -405,12 +404,16 @@ def sync_project_from_kitsu(dbcon: AvalonMongoDB, project: dict):
]
# Sync project. Create if doesn't exist
project_name = project["name"]
project_dict = get_project(project_name)
if not project_dict:
log.info("Project created: {}".format(project_name))
bulk_writes.append(write_project_to_op(project, dbcon))
# Try to find project document
project_name = project["name"]
if not project_dict:
project_dict = get_project(project_name)
dbcon.Session["AVALON_PROJECT"] = project_name
project_dict = get_project(project_name)
# Query all assets of the local project
zou_ids_and_asset_docs = {