replaced avalon imports in fusion

openpype/hosts/fusion/api/lib.py

@@ -6,8 +6,10 @@ import contextlib
 from bson.objectid import ObjectId
 from Qt import QtGui
 
-from avalon import io
-from openpype.pipeline import switch_container
+from openpype.pipeline import (
+    switch_container,
+    legacy_io,
+)
 from .pipeline import get_current_comp, comp_lock_and_undo_chunk
 
 self = sys.modules[__name__]
@@ -94,8 +96,10 @@ def switch_item(container,
     # so we can use the original name from those.
     if any(not x for x in [asset_name, subset_name, representation_name]):
         _id = ObjectId(container["representation"])
-        representation = io.find_one({"type": "representation", "_id": _id})
-        version, subset, asset, project = io.parenthood(representation)
+        representation = legacy_io.find_one({
+            "type": "representation", "_id": _id
+        })
+        version, subset, asset, project = legacy_io.parenthood(representation)
 
         if asset_name is None:
             asset_name = asset["name"]
@@ -107,14 +111,14 @@ def switch_item(container,
             representation_name = representation["name"]
 
     # Find the new one
-    asset = io.find_one({
+    asset = legacy_io.find_one({
         "name": asset_name,
         "type": "asset"
     })
     assert asset, ("Could not find asset in the database with the name "
                    "'%s'" % asset_name)
 
-    subset = io.find_one({
+    subset = legacy_io.find_one({
         "name": subset_name,
         "type": "subset",
         "parent": asset["_id"]
@@ -122,7 +126,7 @@ def switch_item(container,
     assert subset, ("Could not find subset in the database with the name "
                     "'%s'" % subset_name)
 
-    version = io.find_one(
+    version = legacy_io.find_one(
         {
             "type": "version",
             "parent": subset["_id"]
@@ -134,7 +138,7 @@ def switch_item(container,
         asset_name, subset_name
     )
 
-    representation = io.find_one({
+    representation = legacy_io.find_one({
         "name": representation_name,
         "type": "representation",
         "parent": version["_id"]}

openpype/hosts/fusion/plugins/load/load_sequence.py

@@ -1,10 +1,9 @@
 import os
 import contextlib
 
-from avalon import io
-
 from openpype.pipeline import (
     load,
+    legacy_io,
     get_representation_path,
 )
 from openpype.hosts.fusion.api import (
@@ -212,8 +211,10 @@ class FusionLoadSequence(load.LoaderPlugin):
         path = self._get_first_image(root)
 
         # Get start frame from version data
-        version = io.find_one({"type": "version",
-                               "_id": representation["parent"]})
+        version = legacy_io.find_one({
+            "type": "version",
+            "_id": representation["parent"]
+        })
         start = version["data"].get("frameStart")
         if start is None:
             self.log.warning("Missing start frame for updated version"

openpype/hosts/fusion/plugins/publish/submit_deadline.py

@@ -4,10 +4,10 @@ import getpass
 
 import requests
 
-from avalon import api
-
 import pyblish.api
 
+from openpype.pipeline import legacy_io
+
 
 class FusionSubmitDeadline(pyblish.api.InstancePlugin):
     """Submit current Comp to Deadline
@@ -133,7 +133,7 @@ class FusionSubmitDeadline(pyblish.api.InstancePlugin):
             "FUSION9_MasterPrefs"
         ]
         environment = dict({key: os.environ[key] for key in keys
-                            if key in os.environ}, **api.Session)
+                            if key in os.environ}, **legacy_io.Session)
 
         payload["JobInfo"].update({
             "EnvironmentKeyValue%d" % index: "{key}={value}".format(
@@ -146,7 +146,7 @@ class FusionSubmitDeadline(pyblish.api.InstancePlugin):
         self.log.info(json.dumps(payload, indent=4, sort_keys=True))
 
         # E.g. http://192.168.0.1:8082/api/jobs
-        url = "{}/api/jobs".format(DEADLINE_REST_URL)
+        url = "{}/api/jobs".format(deadline_url)
         response = requests.post(url, json=payload)
         if not response.ok:
             raise Exception(response.text)

openpype/hosts/fusion/scripts/fusion_switch_shot.py

@@ -4,10 +4,8 @@ import sys
 import logging
 
 # Pipeline imports
-import avalon.api
-from avalon import io
-
 from openpype.pipeline import (
+    legacy_io,
     install_host,
     registered_host,
 )
@@ -167,7 +165,7 @@ def update_frame_range(comp, representations):
     """
 
     version_ids = [r["parent"] for r in representations]
-    versions = io.find({"type": "version", "_id": {"$in": version_ids}})
+    versions = legacy_io.find({"type": "version", "_id": {"$in": version_ids}})
     versions = list(versions)
 
     versions = [v for v in versions
@@ -205,12 +203,11 @@ def switch(asset_name, filepath=None, new=True):
 
     # Assert asset name exists
     # It is better to do this here then to wait till switch_shot does it
-    asset = io.find_one({"type": "asset", "name": asset_name})
+    asset = legacy_io.find_one({"type": "asset", "name": asset_name})
     assert asset, "Could not find '%s' in the database" % asset_name
 
     # Get current project
-    self._project = io.find_one({"type": "project",
-                                 "name": avalon.api.Session["AVALON_PROJECT"]})
+    self._project = legacy_io.find_one({"type": "project"})
 
     # Go to comp
     if not filepath:
@@ -241,7 +238,7 @@ def switch(asset_name, filepath=None, new=True):
     current_comp.Print(message)
 
     # Build the session to switch to
-    switch_to_session = avalon.api.Session.copy()
+    switch_to_session = legacy_io.Session.copy()
     switch_to_session["AVALON_ASSET"] = asset['name']
 
     if new:

openpype/hosts/fusion/utility_scripts/switch_ui.py

@@ -5,11 +5,13 @@ import logging
 
 from Qt import QtWidgets, QtCore
 
-from avalon import io
 import qtawesome as qta
 
 from openpype import style
-from openpype.pipeline import install_host
+from openpype.pipeline import (
+    install_host,
+    legacy_io,
+)
 from openpype.hosts.fusion import api
 from openpype.lib.avalon_context import get_workdir_from_session
 
@@ -164,7 +166,7 @@ class App(QtWidgets.QWidget):
         return items
 
     def collect_assets(self):
-        return list(io.find({"type": "asset"}, {"name": True}))
+        return list(legacy_io.find({"type": "asset"}, {"name": True}))
 
     def populate_comp_box(self, files):
         """Ensure we display the filename only but the path is stored as well