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

use query function in submit to deadline

Browse source
This commit is contained in:
Jakub Trllo 2022-07-04 16:37:36 +02:00
parent eedc67edcc
commit 5ba81e8c28
1 changed files with 19 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

26
openpype/modules/deadline/plugins/publish/submit_publish_job.py
View file

@ -11,6 +11,7 @@ import clique
import pyblish.api import pyblish.api
import openpype.api import openpype.api
from openpype.client import get_representations
from openpype.pipeline import ( from openpype.pipeline import (
get_representation_path, get_representation_path,
legacy_io, legacy_io,
@ -18,15 +19,23 @@ from openpype.pipeline import (
from openpype.pipeline.farm.patterning import match_aov_pattern from openpype.pipeline.farm.patterning import match_aov_pattern
def get_resources(version, extension=None): def get_resources(project_name, version, extension=None):
"""Get the files from the specific version.""" """Get the files from the specific version."""
query = {"type": "representation", "parent": version["_id"]}
# TODO this functions seems to be weird
# - it's looking for representation with one extension or first (any)
# representation from a version?
# - not sure how this should work, maybe it does for specific use cases
# but probably can't be used for all resources from 2D workflows
extensions = None
if extension: if extension:
query["name"] = extension extensions = [extension]
repre_docs = list(get_representations(
representation = legacy_io.find_one(query) project_name, version_ids=[version["_id"]], extensions=extensions
assert representation, "This is a bug" ))
assert repre_docs, "This is a bug"
representation = repre_docs[0]
directory = get_representation_path(representation) directory = get_representation_path(representation)
print("Source: ", directory) print("Source: ", directory)
resources = sorted( resources = sorted(
@ -330,13 +339,16 @@ class ProcessSubmittedJobOnFarm(pyblish.api.InstancePlugin):
self.log.info("Preparing to copy ...") self.log.info("Preparing to copy ...")
start = instance.data.get("frameStart") start = instance.data.get("frameStart")
end = instance.data.get("frameEnd") end = instance.data.get("frameEnd")
project_name = legacy_io.active_project()
# get latest version of subset # get latest version of subset
# this will stop if subset wasn't published yet # this will stop if subset wasn't published yet
version = openpype.api.get_latest_version(instance.data.get("asset"), version = openpype.api.get_latest_version(instance.data.get("asset"),
instance.data.get("subset")) instance.data.get("subset"))
# get its files based on extension # get its files based on extension
subset_resources = get_resources(version, representation.get("ext")) subset_resources = get_resources(
project_name, version, representation.get("ext")
)
r_col, _ = clique.assemble(subset_resources) r_col, _ = clique.assemble(subset_resources)
# if override remove all frames we are expecting to be rendered # if override remove all frames we are expecting to be rendered