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

Cleaned up log.info() message creation

Browse source
This commit is contained in:
Jacob Danell 2023-02-28 23:24:55 +01:00 • committed by Milan Kolar
parent bcea2c70a2
commit d9ac1ee952
1 changed files with 96 additions and 75 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -176,17 +176,18 @@ class Listener:
self._update_asset(data) self._update_asset(data)
# Print message # Print message
episode = None ep = None
ep_id = asset.get("episode_id") ep_id = asset.get("episode_id")
if ep_id and ep_id != "": if ep_id and ep_id != "":
episode = gazu.asset.get_episode(ep_id) ep = gazu.asset.get_episode(ep_id)
msg = "Asset created: " msg = "Asset created: {proj_name} - {ep_name}" \
msg = msg + f"{asset['project_name']} - " "{asset_type_name} - {asset_name}".format(
if episode is not None: proj_name=asset["project_name"],
msg = msg + f"{episode['name']}_" ep_name=ep["name"] + " - " if ep is not None else "",
msg = msg + f"{asset['asset_type_name']}_" asset_type_name=asset["asset_type_name"],
msg = msg + f"{asset['name']}" asset_name=asset["name"]
)
log.info(msg) log.info(msg)
def _update_asset(self, data): def _update_asset(self, data):
@ -229,17 +230,18 @@ class Listener:
) )
# Print message # Print message
episode = None ep = None
ep_id = asset["data"]["zou"].get("episode_id") ep_id = asset["data"]["zou"].get("episode_id")
if ep_id and ep_id != "": if ep_id and ep_id != "":
episode = gazu.asset.get_episode(ep_id) ep = gazu.asset.get_episode(ep_id)
msg = "Asset deleted: " msg = "Asset deleted: {proj_name} - {ep_name}" \
msg = msg + f"{asset['data']['zou']['project_name']} - " "{asset_type_name} - {asset_name}".format(
if episode is not None: proj_name=asset["data"]["zou"]["project_name"],
msg = msg + f"{episode['name']}_" ep_name=ep["name"] + " - " if ep is not None else "",
msg = msg + f"{asset['data']['zou']['asset_type_name']}_" asset_type_name=asset["data"]["zou"]["asset_type_name"],
msg = msg + f"'{asset['name']}" asset_name=asset["name"]
)
log.info(msg) log.info(msg)
# == Episode == # == Episode ==
@ -252,15 +254,17 @@ class Listener:
ep = gazu.shot.get_episode(data["episode_id"]) ep = gazu.shot.get_episode(data["episode_id"])
# Insert doc in DB # Insert doc in DB
self.dbcon.insert_one(create_op_asset(episode)) self.dbcon.insert_one(create_op_asset(ep))
# Update # Update
self._update_episode(data) self._update_episode(data)
# Print message # Print message
msg = "Episode created: " msg = "Episode created: {proj_name} - {ep_name}".format(
msg = msg + f"{episode['project_name']} - " proj_name=ep["project_name"],
msg = msg + f"{episode['name']}" ep_name=ep["name"]
)
log.info(msg)
def _update_episode(self, data): def _update_episode(self, data):
"""Update episode into OP DB.""" """Update episode into OP DB."""
@ -283,8 +287,8 @@ class Listener:
# Update # Update
update_op_result = update_op_assets( update_op_result = update_op_assets(
self.dbcon, gazu_project, project_doc, [ self.dbcon, gazu_project, project_doc,
episode], zou_ids_and_asset_docs [ep], zou_ids_and_asset_docs
) )
if update_op_result: if update_op_result:
asset_doc_id, asset_update = update_op_result[0] asset_doc_id, asset_update = update_op_result[0]
@ -294,20 +298,22 @@ class Listener:
"""Delete shot of OP DB.""" """Delete shot of OP DB."""
set_op_project(self.dbcon, data["project_id"]) set_op_project(self.dbcon, data["project_id"])
episode = self.dbcon.find_one({"data.zou.id": data['episode_id']}) ep = self.dbcon.find_one({"data.zou.id": data["episode_id"]})
if episode: if ep:
# Delete # Delete
self.dbcon.delete_one( self.dbcon.delete_one(
{"type": "asset", "data.zou.id": data['episode_id']} {"type": "asset", "data.zou.id": data["episode_id"]}
) )
# Print message # Print message
project = gazu.project.get_project( project = gazu.project.get_project(
episode['data']['zou']['project_id']) ep["data"]["zou"]["project_id"])
msg = "Episode deleted: " msg = "Episode deleted: {proj_name} - {ep_name}".format(
msg = msg + f"{project['name']} - " proj_name=project["name"],
msg = msg + f"{episode['name']}" ep_name=ep["name"]
)
log.info(msg)
# == Sequence == # == Sequence ==
def _new_sequence(self, data): def _new_sequence(self, data):
@ -325,17 +331,17 @@ class Listener:
self._update_sequence(data) self._update_sequence(data)
# Print message # Print message
ep = None
episode = None
ep_id = sequence.get("episode_id") ep_id = sequence.get("episode_id")
if ep_id and ep_id != "": if ep_id and ep_id != "":
episode = gazu.asset.get_episode(ep_id) ep = gazu.asset.get_episode(ep_id)
msg = "Sequence created: " msg = "Sequence created: {proj_name} - {ep_name}" \
msg = msg + f"{sequence['project_name']} - " "{sequence_name}".format(
if episode is not None: proj_name=sequence["project_name"],
msg = msg + f"{episode['name']}_" ep_name=ep["name"] + " - " if ep is not None else "",
msg = msg + f"{sequence['name']}" sequence_name=sequence["name"]
)
log.info(msg) log.info(msg)
def _update_sequence(self, data): def _update_sequence(self, data):
@ -377,12 +383,20 @@ class Listener:
) )
# Print message # Print message
ep = None
ep_id = sequence["data"]["zou"].get("episode_id") ep_id = sequence["data"]["zou"].get("episode_id")
if ep_id and ep_id != "":
ep = gazu.asset.get_episode(ep_id)
gazu_project = gazu.project.get_project( gazu_project = gazu.project.get_project(
sequence['data']['zou']['project_id']) sequence["data"]["zou"]["project_id"])
msg = f"Sequence deleted: "
msg = msg + f"{gazu_project['name']} - " msg = "Sequence created: {proj_name} - {ep_name}" \
msg = msg + f"{sequence['name']}" "{sequence_name}".format(
proj_name=gazu_project["name"],
ep_name=ep["name"] + " - " if ep is not None else "",
sequence_name=sequence["name"]
)
log.info(msg) log.info(msg)
# == Shot == # == Shot ==
@ -401,16 +415,17 @@ class Listener:
self._update_shot(data) self._update_shot(data)
# Print message # Print message
episode = None ep = None
if shot["episode_id"] and shot["episode_id"] != "": if shot["episode_id"] and shot["episode_id"] != "":
episode = gazu.asset.get_episode(shot['episode_id']) ep = gazu.asset.get_episode(shot["episode_id"])
msg = "Shot created: " msg = "Shot created: {proj_name} - {ep_name}" \
msg = msg + f"{shot['project_name']} - " "{sequence_name} - {shot_name}".format(
if episode is not None: proj_name=shot["project_name"],
msg = msg + f"{episode['name']}_" ep_name=ep["name"] + " - " if ep is not None else "",
msg = msg + f"{shot['sequence_name']}_" sequence_name=shot["sequence_name"],
msg = msg + f"{shot['name']}" shot_name=shot["name"]
)
log.info(msg) log.info(msg)
def _update_shot(self, data): def _update_shot(self, data):
@ -430,7 +445,6 @@ class Listener:
if asset_doc["data"].get("zou", {}).get("id")} if asset_doc["data"].get("zou", {}).get("id")}
zou_ids_and_asset_docs[shot["project_id"]] = project_doc zou_ids_and_asset_docs[shot["project_id"]] = project_doc
gazu_project = gazu.project.get_project(shot["project_id"]) gazu_project = gazu.project.get_project(shot["project_id"])
gazu_project = gazu.project.get_project(shot['project_id'])
# Update # Update
update_op_result = update_op_assets( update_op_result = update_op_assets(
@ -454,12 +468,18 @@ class Listener:
) )
# Print message # Print message
gazu_project = gazu.project.get_project( ep = None
ep_id = shot["data"]["zou"].get("episode_id") ep_id = shot["data"]["zou"].get("episode_id")
if ep_id and ep_id != "":
ep = gazu.asset.get_episode(ep_id)
msg = "Shot deleted: " msg = "Shot deleted: {proj_name} - {ep_name}" \
msg = msg + f"{gazu_project['name']} - " "{sequence_name} - {shot_name}".format(
msg = msg + f"{shot['name']}" proj_name=shot["data"]["zou"]["project_name"],
ep_name=ep["name"] + " - " if ep is not None else "",
sequence_name=shot["data"]["zou"]["sequence_name"],
shot_name=shot["name"]
)
log.info(msg) log.info(msg)
# == Task == # == Task ==
@ -472,14 +492,14 @@ class Listener:
# Get gazu entity # Get gazu entity
task = gazu.task.get_task(data["task_id"]) task = gazu.task.get_task(data["task_id"])
# Find asset doc # Print message
episode = None ep = None
ep_id = task.get("episode_id") ep_id = task.get("episode_id")
if ep_id and ep_id != "": if ep_id and ep_id != "":
episode = gazu.asset.get_episode(ep_id) ep = gazu.asset.get_episode(ep_id)
parent_name = "" parent_name = None
if episode is not None: entity_type = None
parent_name = episode['name'] + "_" parent_name = episode['name'] + "_"
parent_name = parent_name + \ parent_name = parent_name + \
task['sequence']['name'] + "_" + task['entity']['name'] task['sequence']['name'] + "_" + task['entity']['name']
@ -496,13 +516,13 @@ class Listener:
) )
# Print message # Print message
msg = "Task created: " msg = "Task created: {proj_name} - {entity_type}{parent_name}" \
msg = msg + f"{task['project']['name']} - " " - {task_name}".format(
if episode is not None: proj_name=task["project"]["name"],
msg = msg + f"{episode['name']}_" entity_type=entity_type + " - " if entity_type is not None else "",
msg = msg + f"{task['sequence']['name']}_" parent_name=parent_name,
msg = msg + f"{task['entity']['name']} - " task_name=task["task_type"]["name"]
msg = msg + f"{task['task_type']['name']}" )
log.info(msg) log.info(msg)
def _update_task(self, data): def _update_task(self, data):
@ -533,19 +553,20 @@ class Listener:
# Print message # Print message
entity = gazu.entity.get_entity(task["zou"]["entity_id"]) entity = gazu.entity.get_entity(task["zou"]["entity_id"])
episode = None ep = None
ep_id = entity.get("episode_id") ep_id = entity.get("episode_id")
if ep_id and ep_id != "": if ep_id and ep_id != "":
episode = gazu.asset.get_episode(ep_id) ep = gazu.asset.get_episode(ep_id)
msg = "Task deleted: " msg = "Task deleted: {proj_name} - {entity_type}{parent_name}" \
msg = msg + f"{shot['project_name']} - " " - {task_name}".format(
if episode is not None: proj_name=task["zou"]["project"]["name"],
msg = msg + f"{episode['name']}_" entity_type=entity_type + " - " if entity_type is not None else "",
msg = msg + f"{shot['sequence_name']}_" parent_name=parent_name,
msg = msg + f"{shot['name']} - " task_name=task["type"]
msg = msg + f"{task['type']}" )
log.info(msg) log.info(msg)
return return