mirror of
https://github.com/ynput/ayon-core.git
synced 2026-01-01 16:34:53 +01:00
f8b943bc42
fix(global): initialize avalon io for shell hosts fix(global): changed default family for collect_context from shell fix(global): fixed collection for new integrator
76 lines
2.5 KiB
Python
76 lines
2.5 KiB
Python
import os
|
|
import pyblish.api
|
|
from avalon import io
|
|
import json
|
|
import logging
|
|
import clique
|
|
|
|
log = logging.getLogger("collector")
|
|
|
|
|
|
class CollectContextDataSAPublish(pyblish.api.ContextPlugin):
|
|
"""
|
|
Collecting temp json data sent from a host context
|
|
and path for returning json data back to hostself.
|
|
"""
|
|
|
|
label = "Collect Context - SA Publish"
|
|
order = pyblish.api.CollectorOrder - 0.49
|
|
hosts = ["standalonepublisher"]
|
|
|
|
def process(self, context):
|
|
# get json paths from os and load them
|
|
io.install()
|
|
input_json_path = os.environ.get("SAPUBLISH_INPATH")
|
|
output_json_path = os.environ.get("SAPUBLISH_OUTPATH")
|
|
|
|
# context.data["stagingDir"] = os.path.dirname(input_json_path)
|
|
context.data["returnJsonPath"] = output_json_path
|
|
|
|
with open(input_json_path, "r") as f:
|
|
in_data = json.load(f)
|
|
|
|
asset_name = in_data['asset']
|
|
family = in_data['family']
|
|
subset = in_data['subset']
|
|
|
|
project = io.find_one({'type': 'project'})
|
|
asset = io.find_one({
|
|
'type': 'asset',
|
|
'name': asset_name
|
|
})
|
|
context.data['project'] = project
|
|
context.data['asset'] = asset
|
|
|
|
instance = context.create_instance(subset)
|
|
|
|
instance.data.update({
|
|
"subset": subset,
|
|
"asset": asset_name,
|
|
"label": subset,
|
|
"name": subset,
|
|
"family": family,
|
|
"families": [family, 'ftrack'],
|
|
})
|
|
self.log.info("collected instance: {}".format(instance.data))
|
|
self.log.info("parsing data: {}".format(in_data))
|
|
|
|
instance.data['destination_list'] = list()
|
|
instance.data['representations'] = list()
|
|
instance.data['source'] = 'standalone publisher'
|
|
|
|
for component in in_data['representations']:
|
|
|
|
component['destination'] = component['files']
|
|
component['stagingDir'] = component['stagingDir']
|
|
component['anatomy_template'] = 'render'
|
|
if isinstance(component['files'], list):
|
|
collections, remainder = clique.assemble(component['files'])
|
|
self.log.debug("collecting sequence: {}".format(collections))
|
|
instance.data['startFrame'] = int(component['startFrame'])
|
|
instance.data['endFrame'] = int(component['endFrame'])
|
|
instance.data['frameRate'] = int(component['frameRate'])
|
|
|
|
instance.data["representations"].append(component)
|
|
|
|
self.log.info(in_data)
|