General: Reduce usage of legacy io

openpype/hooks/pre_global_host_data.py

@@ -5,7 +5,7 @@
     prepare_app_environments,
     prepare_context_environments
 )
-from openpype.pipeline import AvalonMongoDB, Anatomy
+from openpype.pipeline import Anatomy
 
 
 class GlobalHostDataHook(PreLaunchHook):
@@ -26,7 +26,6 @@ def execute(self):
 
             "app": app,
 
-            "dbcon": self.data["dbcon"],
             "project_doc": self.data["project_doc"],
             "asset_doc": self.data["asset_doc"],
 
@@ -62,13 +61,6 @@ def prepare_global_data(self):
         # Anatomy
         self.data["anatomy"] = Anatomy(project_name)
 
-        # Mongo connection
-        dbcon = AvalonMongoDB()
-        dbcon.Session["AVALON_PROJECT"] = project_name
-        dbcon.install()
-
-        self.data["dbcon"] = dbcon
-
         # Project document
         project_doc = get_project(project_name)
         self.data["project_doc"] = project_doc

openpype/host/dirmap.py

@@ -149,7 +149,7 @@ def _get_local_sync_dirmap(self):
             Returns:
                 dict : { "source-path": [XXX], "destination-path": [YYYY]}
         """
-        project_name = os.getenv("AVALON_PROJECT")
+        project_name = self.project_name
 
         mapping = {}
         if (not self.sync_module.enabled or

openpype/hosts/aftereffects/api/pipeline.py

@@ -8,10 +8,7 @@
 from openpype.pipeline import (
     register_loader_plugin_path,
     register_creator_plugin_path,
-    deregister_loader_plugin_path,
-    deregister_creator_plugin_path,
     AVALON_CONTAINER_ID,
-    legacy_io,
 )
 from openpype.pipeline.load import any_outdated_containers
 import openpype.hosts.aftereffects

openpype/hosts/aftereffects/plugins/publish/collect_render.py

@@ -53,6 +53,7 @@ def get_instances(self, context):
         version = context.data["version"]
 
         project_entity = context.data["projectEntity"]
+        project_settings = context.data["project_settings"]
 
         compositions = CollectAERender.get_stub().get_items(True)
         compositions_by_id = {item.id: item for item in compositions}
@@ -131,7 +132,9 @@ def get_instances(self, context):
                 is_local = not inst.data["creator_attributes"].get("farm")
             if is_local:
                 # for local renders
-                instance = self._update_for_local(instance, project_entity)
+                instance = self._update_for_local(
+                    instance, project_entity, project_settings
+                )
             else:
                 fam = "render.farm"
                 if fam not in instance.families:
@@ -210,16 +213,15 @@ def _get_output_dir(self, render_instance):
         # for submit_publish_job
         return base_dir
 
-    def _update_for_local(self, instance, project_entity):
+    def _update_for_local(self, instance, project_entity, project_settings):
         """Update old saved instances to current publishing format"""
         instance.stagingDir = tempfile.mkdtemp()
         instance.projectEntity = project_entity
         fam = "render.local"
         if fam not in instance.families:
             instance.families.append(fam)
 
-        settings = get_project_settings(os.getenv("AVALON_PROJECT"))
-        reviewable_subset_filter = (settings["deadline"]
+        reviewable_subset_filter = (project_settings["deadline"]
                                     ["publish"]
                                     ["ProcessSubmittedJobOnFarm"]
                                     ["aov_filter"].get(self.hosts[0]))

openpype/hosts/aftereffects/plugins/publish/collect_workfile.py

@@ -1,7 +1,6 @@
 import os
 
 import pyblish.api
-from openpype.pipeline import legacy_io
 from openpype.pipeline.create import get_subset_name
 
 
@@ -44,7 +43,7 @@ def process(self, context):
         instance.data["publish"] = instance.data["active"]  # for DL
 
     def _get_new_instance(self, context, scene_file):
-        task = legacy_io.Session["AVALON_TASK"]
+        task = context.data["task"]
         version = context.data["version"]
         asset_entity = context.data["assetEntity"]
         project_entity = context.data["projectEntity"]

openpype/hosts/aftereffects/plugins/publish/validate_instance_asset.py

@@ -1,6 +1,6 @@
 import pyblish.api
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_asset_name
 from openpype.pipeline.publish import (
     ValidateContentsOrder,
     PublishXmlValidationError,
@@ -30,7 +30,7 @@ def process(self, context, plugin):
         for instance in instances:
             data = stub.read(instance[0])
 
-            data["asset"] = legacy_io.Session["AVALON_ASSET"]
+            data["asset"] = get_current_asset_name()
             stub.imprint(instance[0].instance_id, data)
 
 
@@ -54,7 +54,7 @@ class ValidateInstanceAsset(pyblish.api.InstancePlugin):
 
     def process(self, instance):
         instance_asset = instance.data["asset"]
-        current_asset = legacy_io.Session["AVALON_ASSET"]
+        current_asset = get_current_asset_name()
         msg = (
             f"Instance asset {instance_asset} is not the same "
             f"as current context {current_asset}."

openpype/hosts/blender/api/ops.py

@@ -16,7 +16,7 @@
 import bpy.utils.previews
 
 from openpype import style
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_asset_name, get_current_task_name
 from openpype.tools.utils import host_tools
 
 from .workio import OpenFileCacher
@@ -283,7 +283,7 @@ class LaunchLoader(LaunchQtApp):
 
     def before_window_show(self):
         self._window.set_context(
-            {"asset": legacy_io.Session["AVALON_ASSET"]},
+            {"asset": get_current_asset_name()},
             refresh=True
         )
 
@@ -331,8 +331,8 @@ class LaunchWorkFiles(LaunchQtApp):
     def execute(self, context):
         result = super().execute(context)
         self._window.set_context({
-            "asset": legacy_io.Session["AVALON_ASSET"],
-            "task": legacy_io.Session["AVALON_TASK"]
+            "asset": get_current_asset_name(),
+            "task": get_current_task_name()
         })
         return result
 
@@ -362,8 +362,8 @@ def draw(self, context):
         else:
             pyblish_menu_icon_id = 0
 
-        asset = legacy_io.Session['AVALON_ASSET']
-        task = legacy_io.Session['AVALON_TASK']
+        asset = get_current_asset_name()
+        task = get_current_task_name()
         context_label = f"{asset}, {task}"
         context_label_item = layout.row()
         context_label_item.operator(

openpype/hosts/blender/api/pipeline.py

@@ -14,6 +14,8 @@
 from openpype.pipeline import (
     schema,
     legacy_io,
+    get_current_project_name,
+    get_current_asset_name,
     register_loader_plugin_path,
     register_creator_plugin_path,
     deregister_loader_plugin_path,
@@ -84,8 +86,8 @@ def uninstall():
 
 
 def set_start_end_frames():
-    project_name = legacy_io.active_project()
-    asset_name = legacy_io.Session["AVALON_ASSET"]
+    project_name = get_current_project_name()
+    asset_name = get_current_asset_name()
     asset_doc = get_asset_by_name(project_name, asset_name)
 
     scene = bpy.context.scene

openpype/hosts/blender/plugins/create/create_action.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 import openpype.hosts.blender.api.plugin
 from openpype.hosts.blender.api import lib
 
@@ -22,7 +22,7 @@ def process(self):
         name = openpype.hosts.blender.api.plugin.asset_name(asset, subset)
         collection = bpy.data.collections.new(name=name)
         bpy.context.scene.collection.children.link(collection)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         lib.imprint(collection, self.data)
 
         if (self.options or {}).get("useSelection"):

openpype/hosts/blender/plugins/create/create_animation.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 from openpype.hosts.blender.api import plugin, lib, ops
 from openpype.hosts.blender.api.pipeline import AVALON_INSTANCES
 
@@ -37,7 +37,7 @@ def _process(self):
         # asset_group.empty_display_type = 'SINGLE_ARROW'
         asset_group = bpy.data.collections.new(name=name)
         instances.children.link(asset_group)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         lib.imprint(asset_group, self.data)
 
         if (self.options or {}).get("useSelection"):

openpype/hosts/blender/plugins/create/create_camera.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 from openpype.hosts.blender.api import plugin, lib, ops
 from openpype.hosts.blender.api.pipeline import AVALON_INSTANCES
 
@@ -35,7 +35,7 @@ def _process(self):
         asset_group = bpy.data.objects.new(name=name, object_data=None)
         asset_group.empty_display_type = 'SINGLE_ARROW'
         instances.objects.link(asset_group)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         print(f"self.data: {self.data}")
         lib.imprint(asset_group, self.data)
 

openpype/hosts/blender/plugins/create/create_layout.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 from openpype.hosts.blender.api import plugin, lib, ops
 from openpype.hosts.blender.api.pipeline import AVALON_INSTANCES
 
@@ -34,7 +34,7 @@ def _process(self):
         asset_group = bpy.data.objects.new(name=name, object_data=None)
         asset_group.empty_display_type = 'SINGLE_ARROW'
         instances.objects.link(asset_group)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         lib.imprint(asset_group, self.data)
 
         # Add selected objects to instance

openpype/hosts/blender/plugins/create/create_model.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 from openpype.hosts.blender.api import plugin, lib, ops
 from openpype.hosts.blender.api.pipeline import AVALON_INSTANCES
 
@@ -34,7 +34,7 @@ def _process(self):
         asset_group = bpy.data.objects.new(name=name, object_data=None)
         asset_group.empty_display_type = 'SINGLE_ARROW'
         instances.objects.link(asset_group)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         lib.imprint(asset_group, self.data)
 
         # Add selected objects to instance

openpype/hosts/blender/plugins/create/create_pointcache.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 import openpype.hosts.blender.api.plugin
 from openpype.hosts.blender.api import lib
 
@@ -22,7 +22,7 @@ def process(self):
         name = openpype.hosts.blender.api.plugin.asset_name(asset, subset)
         collection = bpy.data.collections.new(name=name)
         bpy.context.scene.collection.children.link(collection)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         lib.imprint(collection, self.data)
 
         if (self.options or {}).get("useSelection"):

openpype/hosts/blender/plugins/create/create_review.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 from openpype.hosts.blender.api import plugin, lib, ops
 from openpype.hosts.blender.api.pipeline import AVALON_INSTANCES
 
@@ -33,7 +33,7 @@ def _process(self):
         name = plugin.asset_name(asset, subset)
         asset_group = bpy.data.collections.new(name=name)
         instances.children.link(asset_group)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         lib.imprint(asset_group, self.data)
 
         if (self.options or {}).get("useSelection"):

openpype/hosts/blender/plugins/create/create_rig.py

@@ -2,7 +2,7 @@
 
 import bpy
 
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name
 from openpype.hosts.blender.api import plugin, lib, ops
 from openpype.hosts.blender.api.pipeline import AVALON_INSTANCES
 
@@ -34,7 +34,7 @@ def _process(self):
         asset_group = bpy.data.objects.new(name=name, object_data=None)
         asset_group.empty_display_type = 'SINGLE_ARROW'
         instances.objects.link(asset_group)
-        self.data['task'] = legacy_io.Session.get('AVALON_TASK')
+        self.data['task'] = get_current_task_name()
         lib.imprint(asset_group, self.data)
 
         # Add selected objects to instance

openpype/hosts/blender/plugins/publish/collect_current_file.py

@@ -2,7 +2,7 @@
 import bpy
 
 import pyblish.api
-from openpype.pipeline import legacy_io
+from openpype.pipeline import get_current_task_name, get_current_asset_name
 from openpype.hosts.blender.api import workio
 
 
@@ -37,7 +37,7 @@ def process(self, context):
         folder, file = os.path.split(current_file)
         filename, ext = os.path.splitext(file)
 
-        task = legacy_io.Session["AVALON_TASK"]
+        task = get_current_task_name()
 
         data = {}
 
@@ -47,7 +47,7 @@ def process(self, context):
 
         data.update({
             "subset": subset,
-            "asset": os.getenv("AVALON_ASSET", None),
+            "asset": get_current_asset_name(),
             "label": subset,
             "publish": True,
             "family": "workfile",

openpype/hosts/blender/plugins/publish/collect_review.py

@@ -1,7 +1,6 @@
 import bpy
 
 import pyblish.api
-from openpype.pipeline import legacy_io
 
 
 class CollectReview(pyblish.api.InstancePlugin):
@@ -39,7 +38,7 @@ def process(self, instance):
 
         if not instance.data.get("remove"):
 
-            task = legacy_io.Session.get("AVALON_TASK")
+            task = instance.context.data["task"]
 
             instance.data.update({
                 "subset": f"{task}Review",

openpype/hosts/celaction/plugins/publish/collect_celaction_instances.py

@@ -1,6 +1,5 @@
 import os
 import pyblish.api
-from openpype.pipeline import legacy_io
 
 
 class CollectCelactionInstances(pyblish.api.ContextPlugin):
@@ -10,7 +9,7 @@ class CollectCelactionInstances(pyblish.api.ContextPlugin):
     order = pyblish.api.CollectorOrder + 0.1
 
     def process(self, context):
-        task = legacy_io.Session["AVALON_TASK"]
+        task = context.data["task"]
         current_file = context.data["currentFile"]
         staging_dir = os.path.dirname(current_file)
         scene_file = os.path.basename(current_file)