use 'OpenPypeMongoConnection' from 'openpype.client'

openpype/hosts/maya/api/shader_definition_editor.py

@@ -6,7 +6,7 @@ Shader names are stored as simple text file over GridFS in mongodb.
 """
 import os
 from Qt import QtWidgets, QtCore, QtGui
-from openpype.lib.mongo import OpenPypeMongoConnection
+from openpype.client.mongo import OpenPypeMongoConnection
 from openpype import resources
 import gridfs
 

openpype/hosts/maya/plugins/publish/validate_model_name.py

@@ -10,7 +10,7 @@ from openpype.pipeline import legacy_io
 import openpype.hosts.maya.api.action
 from openpype.hosts.maya.api.shader_definition_editor import (
     DEFINITION_FILENAME)
-from openpype.lib.mongo import OpenPypeMongoConnection
+from openpype.client.mongo import OpenPypeMongoConnection
 import gridfs
 
 

openpype/hosts/webpublisher/webserver_service/webpublish_routes.py

@@ -10,9 +10,9 @@ from aiohttp.web_response import Response
 from openpype.client import (
     get_projects,
     get_assets,
+    OpenPypeMongoConnection,
 )
 from openpype.lib import (
-    OpenPypeMongoConnection,
     PypeLogger,
 )
 from openpype.lib.remote_publish import (

openpype/hosts/webpublisher/webserver_service/webserver_cli.py

@@ -6,6 +6,7 @@ import requests
 import json
 import subprocess
 
+from openpype.client import OpenPypeMongoConnection
 from openpype.lib import PypeLogger
 
 from .webpublish_routes import (
@@ -121,8 +122,6 @@ def run_webserver(*args, **kwargs):
 
 def reprocess_failed(upload_dir, webserver_url):
     # log.info("check_reprocesable_records")
-    from openpype.lib import OpenPypeMongoConnection
-
     mongo_client = OpenPypeMongoConnection.get_mongo_client()
     database_name = os.environ["OPENPYPE_DATABASE_NAME"]
     dbcon = mongo_client[database_name]["webpublishes"]

openpype/lib/local_settings.py

@@ -34,7 +34,7 @@ from openpype.settings import (
     get_system_settings
 )
 
-from .import validate_mongo_connection
+from openpype.client.mongo import validate_mongo_connection
 
 _PLACEHOLDER = object()
 

openpype/lib/log.py

@@ -24,12 +24,13 @@ import traceback
 import threading
 import copy
 
-from . import Terminal
+from openpype.client.mongo import (
-from .mongo import (
     MongoEnvNotSet,
     get_default_components,
-    OpenPypeMongoConnection
+    OpenPypeMongoConnection,
 )
+from . import Terminal
+
 try:
     import log4mongo
     from log4mongo.handlers import MongoHandler

openpype/lib/remote_publish.py

@@ -7,7 +7,7 @@ from bson.objectid import ObjectId
 import pyblish.util
 import pyblish.api
 
-from openpype.lib.mongo import OpenPypeMongoConnection
+from openpype.client.mongo import OpenPypeMongoConnection
 from openpype.lib.plugin_tools import parse_json
 
 ERROR_STATUS = "error"

openpype/modules/ftrack/ftrack_server/event_server_cli.py

@@ -1,11 +1,9 @@
 import os
-import sys
 import signal
 import datetime
 import subprocess
 import socket
 import json
-import platform
 import getpass
 import atexit
 import time
@@ -13,12 +11,14 @@ import uuid
 
 import ftrack_api
 import pymongo
+from openpype.client.mongo import (
+    OpenPypeMongoConnection,
+    validate_mongo_connection,
+)
 from openpype.lib import (
     get_openpype_execute_args,
-    OpenPypeMongoConnection,
     get_openpype_version,
     get_build_version,
-    validate_mongo_connection
 )
 from openpype_modules.ftrack import FTRACK_MODULE_DIR
 from openpype_modules.ftrack.lib import credentials

openpype/modules/ftrack/ftrack_server/lib.py

@@ -24,7 +24,7 @@ except ImportError:
     from ftrack_api._weakref import WeakMethod
 from openpype_modules.ftrack.lib import get_ftrack_event_mongo_info
 
-from openpype.lib import OpenPypeMongoConnection
+from openpype.client import OpenPypeMongoConnection
 from openpype.api import Logger
 
 TOPIC_STATUS_SERVER = "openpype.event.server.status"

openpype/modules/ftrack/scripts/sub_event_storer.py

@@ -6,6 +6,8 @@ import socket
 import pymongo
 
 import ftrack_api
+
+from openpype.client import OpenPypeMongoConnection
 from openpype_modules.ftrack.ftrack_server.ftrack_server import FtrackServer
 from openpype_modules.ftrack.ftrack_server.lib import (
     SocketSession,
@@ -15,7 +17,6 @@ from openpype_modules.ftrack.ftrack_server.lib import (
 )
 from openpype_modules.ftrack.lib import get_ftrack_event_mongo_info
 from openpype.lib import (
-    OpenPypeMongoConnection,
     get_openpype_version,
     get_build_version
 )

openpype/modules/slack/plugins/publish/integrate_slack_api.py

@@ -4,8 +4,8 @@ import pyblish.api
 import copy
 from datetime import datetime
 
+from openpype.client import OpenPypeMongoConnection
 from openpype.lib.plugin_tools import prepare_template_data
-from openpype.lib import OpenPypeMongoConnection
 
 
 class IntegrateSlackAPI(pyblish.api.InstancePlugin):

openpype/pipeline/mongodb.py

@@ -5,6 +5,8 @@ import logging
 import pymongo
 from uuid import uuid4
 
+from openpype.client import OpenPypeMongoConnection
+
 from . import schema
 
 
@@ -156,8 +158,6 @@ class AvalonMongoDB:
 
     @property
     def mongo_client(self):
-        from openpype.lib import OpenPypeMongoConnection
-
         return OpenPypeMongoConnection.get_mongo_client()
 
     @property

openpype/settings/handlers.py

@@ -7,6 +7,7 @@ from abc import ABCMeta, abstractmethod
 import six
 
 import openpype.version
+from openpype.client.mongo import OpenPypeMongoConnection
 
 from .constants import (
     GLOBAL_SETTINGS_KEY,
@@ -337,7 +338,6 @@ class MongoSettingsHandler(SettingsHandler):
 
     def __init__(self):
         # Get mongo connection
-        from openpype.lib import OpenPypeMongoConnection
         from openpype.pipeline import AvalonMongoDB
 
         settings_collection = OpenPypeMongoConnection.get_mongo_client()