diff --git a/openpype/client/entities.py b/openpype/client/entities.py
index f1f1d30214c..3d2730a17ce 100644
--- a/openpype/client/entities.py
+++ b/openpype/client/entities.py
@@ -1455,7 +1455,7 @@ def get_workfile_info(
 """
 ## Custom data storage:
 - Settings - OP settings overrides and local settings
-- Logging - logs from PypeLogger
+- Logging - logs from Logger
 - Webpublisher - jobs
 - Ftrack - events
 - Maya - Shaders
diff --git a/openpype/hosts/celaction/api/cli.py b/openpype/hosts/celaction/api/cli.py
index 8c7b3a2e740..eb91def0907 100644
--- a/openpype/hosts/celaction/api/cli.py
+++ b/openpype/hosts/celaction/api/cli.py
@@ -14,7 +14,7 @@
 from openpype.pipeline import install_openpype_plugins
 
 
-log = Logger().get_logger("Celaction_cli_publisher")
+log = Logger.get_logger("Celaction_cli_publisher")
 
 publish_host = "celaction"
 
diff --git a/openpype/hosts/fusion/api/pipeline.py b/openpype/hosts/fusion/api/pipeline.py
index 54002f9f51f..54a6c94b608 100644
--- a/openpype/hosts/fusion/api/pipeline.py
+++ b/openpype/hosts/fusion/api/pipeline.py
@@ -8,7 +8,7 @@
 
 import pyblish.api
 
-from openpype.api import Logger
+from openpype.lib import Logger
 from openpype.pipeline import (
     register_loader_plugin_path,
     register_creator_plugin_path,
@@ -20,7 +20,7 @@
 )
 import openpype.hosts.fusion
 
-log = Logger().get_logger(__name__)
+log = Logger.get_logger(__name__)
 
 HOST_DIR = os.path.dirname(os.path.abspath(openpype.hosts.fusion.__file__))
 PLUGINS_DIR = os.path.join(HOST_DIR, "plugins")
diff --git a/openpype/hosts/fusion/utility_scripts/__OpenPype_Menu__.py b/openpype/hosts/fusion/utility_scripts/__OpenPype_Menu__.py
index de8fc4b3b44..870e74280a3 100644
--- a/openpype/hosts/fusion/utility_scripts/__OpenPype_Menu__.py
+++ b/openpype/hosts/fusion/utility_scripts/__OpenPype_Menu__.py
@@ -1,14 +1,12 @@
 import os
 import sys
 
-from openpype.api import Logger
+from openpype.lib import Logger
 from openpype.pipeline import (
     install_host,
     registered_host,
 )
 
-log = Logger().get_logger(__name__)
-
 
 def main(env):
     from openpype.hosts.fusion import api
@@ -17,6 +15,7 @@ def main(env):
     # activate resolve from pype
     install_host(api)
 
+    log = Logger.get_logger(__name__)
     log.info(f"Registered host: {registered_host()}")
 
     menu.launch_openpype_menu()
diff --git a/openpype/hosts/hiero/api/events.py b/openpype/hosts/hiero/api/events.py
index 59fd278a81a..862a2607c1d 100644
--- a/openpype/hosts/hiero/api/events.py
+++ b/openpype/hosts/hiero/api/events.py
@@ -1,7 +1,6 @@
 import os
 import hiero.core.events
-from openpype.api import Logger
-from openpype.lib import register_event_callback
+from openpype.lib import Logger, register_event_callback
 from .lib import (
     sync_avalon_data_to_workfile,
     launch_workfiles_app,
@@ -11,7 +10,7 @@
 from .tags import add_tags_to_workfile
 from .menu import update_menu_task_label
 
-log = Logger().get_logger(__name__)
+log = Logger.get_logger(__name__)
 
 
 def startupCompleted(event):
diff --git a/openpype/hosts/hiero/api/lib.py b/openpype/hosts/hiero/api/lib.py
index 2f66f3ddd71..e288cea2b18 100644
--- a/openpype/hosts/hiero/api/lib.py
+++ b/openpype/hosts/hiero/api/lib.py
@@ -21,7 +21,7 @@
 )
 from openpype.settings import get_anatomy_settings
 from openpype.pipeline import legacy_io, Anatomy
-from openpype.api import Logger
+from openpype.lib import Logger
 from . import tags
 
 try:
@@ -34,7 +34,7 @@
 # from opentimelineio import opentime
 # from pprint import pformat
 
-log = Logger().get_logger(__name__)
+log = Logger.get_logger(__name__)
 
 self = sys.modules[__name__]
 self._has_been_setup = False
diff --git a/openpype/hosts/hiero/api/pipeline.py b/openpype/hosts/hiero/api/pipeline.py
index b243a38b068..dacfd338bb7 100644
--- a/openpype/hosts/hiero/api/pipeline.py
+++ b/openpype/hosts/hiero/api/pipeline.py
@@ -6,7 +6,7 @@
 from collections import OrderedDict
 
 from pyblish import api as pyblish
-from openpype.api import Logger
+from openpype.lib import Logger
 from openpype.pipeline import (
     schema,
     register_creator_plugin_path,
@@ -18,7 +18,7 @@
 from openpype.tools.utils import host_tools
 from . import lib, menu, events
 
-log = Logger().get_logger(__name__)
+log = Logger.get_logger(__name__)
 
 # plugin paths
 API_DIR = os.path.dirname(os.path.abspath(__file__))
diff --git a/openpype/hosts/hiero/api/plugin.py b/openpype/hosts/hiero/api/plugin.py
index 28a9dfb492d..77fedbbbdc4 100644
--- a/openpype/hosts/hiero/api/plugin.py
+++ b/openpype/hosts/hiero/api/plugin.py
@@ -9,11 +9,12 @@
 import qargparse
 
 import openpype.api as openpype
+from openpype.lib import Logger
 from openpype.pipeline import LoaderPlugin, LegacyCreator
 from openpype.pipeline.context_tools import get_current_project_asset
 from . import lib
 
-log = openpype.Logger().get_logger(__name__)
+log = Logger.get_logger(__name__)
 
 
 def load_stylesheet():
diff --git a/openpype/hosts/maya/api/plugin.py b/openpype/hosts/maya/api/plugin.py
index e50ebfccad6..39d821f6208 100644
--- a/openpype/hosts/maya/api/plugin.py
+++ b/openpype/hosts/maya/api/plugin.py
@@ -4,6 +4,7 @@
 
 import qargparse
 
+from openpype.lib import Logger
 from openpype.pipeline import (
     LegacyCreator,
     LoaderPlugin,
@@ -50,9 +51,7 @@ def get_reference_node(members, log=None):
     # Warn the user when we're taking the highest reference node
     if len(references) > 1:
         if not log:
-            from openpype.lib import PypeLogger
-
-            log = PypeLogger().get_logger(__name__)
+            log = Logger.get_logger(__name__)
 
         log.warning("More than one reference node found in "
                     "container, using highest reference node: "
diff --git a/openpype/hosts/nuke/plugins/load/actions.py b/openpype/hosts/nuke/plugins/load/actions.py
index d364a4f3a1f..69f56c73057 100644
--- a/openpype/hosts/nuke/plugins/load/actions.py
+++ b/openpype/hosts/nuke/plugins/load/actions.py
@@ -2,10 +2,10 @@
 
 """
 
-from openpype.api import Logger
+from openpype.lib import Logger
 from openpype.pipeline import load
 
-log = Logger().get_logger(__name__)
+log = Logger.get_logger(__name__)
 
 
 class SetFrameRangeLoader(load.LoaderPlugin):
diff --git a/openpype/hosts/nuke/startup/clear_rendered.py b/openpype/hosts/nuke/startup/clear_rendered.py
index cf1d8ce1701..744af710346 100644
--- a/openpype/hosts/nuke/startup/clear_rendered.py
+++ b/openpype/hosts/nuke/startup/clear_rendered.py
@@ -1,10 +1,11 @@
 import os
 
-from openpype.api import Logger
-log = Logger().get_logger(__name__)
+from openpype.lib import Logger
 
 
 def clear_rendered(dir_path):
+    log = Logger.get_logger(__name__)
+
     for _f in os.listdir(dir_path):
         _f_path = os.path.join(dir_path, _f)
         log.info("Removing: `{}`".format(_f_path))
diff --git a/openpype/hosts/nuke/startup/write_to_read.py b/openpype/hosts/nuke/startup/write_to_read.py
index f5cf66b357d..b7add40f475 100644
--- a/openpype/hosts/nuke/startup/write_to_read.py
+++ b/openpype/hosts/nuke/startup/write_to_read.py
@@ -2,8 +2,8 @@
 import os
 import glob
 import nuke
-from openpype.api import Logger
-log = Logger().get_logger(__name__)
+from openpype.lib import Logger
+log = Logger.get_logger(__name__)
 
 SINGLE_FILE_FORMATS = ['avi', 'mp4', 'mxf', 'mov', 'mpg', 'mpeg', 'wmv', 'm4v',
                        'm2v']
diff --git a/openpype/hosts/tvpaint/worker/worker_job.py b/openpype/hosts/tvpaint/worker/worker_job.py
index 1c785ab2eeb..95c0a678bce 100644
--- a/openpype/hosts/tvpaint/worker/worker_job.py
+++ b/openpype/hosts/tvpaint/worker/worker_job.py
@@ -9,7 +9,7 @@
 
 import six
 
-from openpype.api import PypeLogger
+from openpype.lib import Logger
 from openpype.modules import ModulesManager
 
 
@@ -328,7 +328,7 @@ def job_queue_root(self):
     def log(self):
         """Access to logger object."""
         if self._log is None:
-            self._log = PypeLogger.get_logger(self.__class__.__name__)
+            self._log = Logger.get_logger(self.__class__.__name__)
         return self._log
 
     @property
diff --git a/openpype/hosts/webpublisher/webserver_service/webpublish_routes.py b/openpype/hosts/webpublisher/webserver_service/webpublish_routes.py
index 6444a5191d1..2e9d460a986 100644
--- a/openpype/hosts/webpublisher/webserver_service/webpublish_routes.py
+++ b/openpype/hosts/webpublisher/webserver_service/webpublish_routes.py
@@ -12,9 +12,7 @@
     get_assets,
     OpenPypeMongoConnection,
 )
-from openpype.lib import (
-    PypeLogger,
-)
+from openpype.lib import Logger
 from openpype.lib.remote_publish import (
     get_task_data,
     ERROR_STATUS,
@@ -23,7 +21,7 @@
 from openpype.settings import get_project_settings
 from openpype_modules.webserver.base_routes import RestApiEndpoint
 
-log = PypeLogger.get_logger("WebpublishRoutes")
+log = Logger.get_logger("WebpublishRoutes")
 
 
 class ResourceRestApiEndpoint(RestApiEndpoint):
diff --git a/openpype/hosts/webpublisher/webserver_service/webserver_cli.py b/openpype/hosts/webpublisher/webserver_service/webserver_cli.py
index 6620e5d5cf1..936bd9735f9 100644
--- a/openpype/hosts/webpublisher/webserver_service/webserver_cli.py
+++ b/openpype/hosts/webpublisher/webserver_service/webserver_cli.py
@@ -7,7 +7,7 @@
 import subprocess
 
 from openpype.client import OpenPypeMongoConnection
-from openpype.lib import PypeLogger
+from openpype.lib import Logger
 
 from .webpublish_routes import (
     RestApiResource,
@@ -28,7 +28,7 @@
 )
 
 
-log = PypeLogger.get_logger("webserver_gui")
+log = Logger.get_logger("webserver_gui")
 
 
 def run_webserver(*args, **kwargs):
diff --git a/openpype/lib/applications.py b/openpype/lib/applications.py
index 074e815160a..73f96078354 100644
--- a/openpype/lib/applications.py
+++ b/openpype/lib/applications.py
@@ -24,7 +24,7 @@
     METADATA_KEYS,
     M_DYNAMIC_KEY_LABEL
 )
-from . import PypeLogger
+from .log import Logger
 from .profiles_filtering import filter_profiles
 from .local_settings import get_openpype_username
 
@@ -138,7 +138,7 @@ def get_logger():
     """Global lib.applications logger getter."""
     global _logger
     if _logger is None:
-        _logger = PypeLogger.get_logger(__name__)
+        _logger = Logger.get_logger(__name__)
     return _logger
 
 
@@ -373,7 +373,7 @@ class ApplicationManager:
     """
 
     def __init__(self, system_settings=None):
-        self.log = PypeLogger.get_logger(self.__class__.__name__)
+        self.log = Logger.get_logger(self.__class__.__name__)
 
         self.app_groups = {}
         self.applications = {}
@@ -735,7 +735,7 @@ def __init__(self, launch_context):
 
         Always should be called
         """
-        self.log = PypeLogger().get_logger(self.__class__.__name__)
+        self.log = Logger.get_logger(self.__class__.__name__)
 
         self.launch_context = launch_context
 
@@ -877,7 +877,7 @@ def __init__(self, application, executable, env_group=None, **data):
 
         # Logger
         logger_name = "{}-{}".format(self.__class__.__name__, self.app_name)
-        self.log = PypeLogger.get_logger(logger_name)
+        self.log = Logger.get_logger(logger_name)
 
         self.executable = executable
 
diff --git a/openpype/lib/execute.py b/openpype/lib/execute.py
index c3e35772f32..f1f2a4fa0a8 100644
--- a/openpype/lib/execute.py
+++ b/openpype/lib/execute.py
@@ -5,7 +5,7 @@
 import json
 import tempfile
 
-from .log import PypeLogger as Logger
+from .log import Logger
 from .vendor_bin_utils import find_executable
 
 # MSDN process creation flag (Windows only)
@@ -40,7 +40,7 @@ def execute(args,
 
     log_levels = ['DEBUG:', 'INFO:', 'ERROR:', 'WARNING:', 'CRITICAL:']
 
-    log = Logger().get_logger('execute')
+    log = Logger.get_logger('execute')
     log.info("Executing ({})".format(" ".join(args)))
     popen = subprocess.Popen(
         args,
diff --git a/openpype/lib/log.py b/openpype/lib/log.py
index e77edea0e9d..26dcd86eecc 100644
--- a/openpype/lib/log.py
+++ b/openpype/lib/log.py
@@ -486,12 +486,18 @@ def get_log_mongo_connection(cls):
 
 
 class PypeLogger(Logger):
+    """Duplicate of 'Logger'.
+
+    Deprecated:
+        Class will be removed after release version 3.16.*
+    """
+
     @classmethod
     def get_logger(cls, *args, **kwargs):
         logger = Logger.get_logger(*args, **kwargs)
         # TODO uncomment when replaced most of places
-        # logger.warning((
-        #     "'openpype.lib.PypeLogger' is deprecated class."
-        #     " Please use 'openpype.lib.Logger' instead."
-        # ))
+        logger.warning((
+            "'openpype.lib.PypeLogger' is deprecated class."
+            " Please use 'openpype.lib.Logger' instead."
+        ))
         return logger
diff --git a/openpype/lib/path_templates.py b/openpype/lib/path_templates.py
index e4b18ec2589..b160054e380 100644
--- a/openpype/lib/path_templates.py
+++ b/openpype/lib/path_templates.py
@@ -6,11 +6,6 @@
 
 import six
 
-from .log import PypeLogger
-
-log = PypeLogger.get_logger(__name__)
-
-
 KEY_PATTERN = re.compile(r"(\{.*?[^{0]*\})")
 KEY_PADDING_PATTERN = re.compile(r"([^:]+)\S+[><]\S+")
 SUB_DICT_PATTERN = re.compile(r"([^\[\]]+)")
diff --git a/openpype/lib/remote_publish.py b/openpype/lib/remote_publish.py
index b4b05c053b0..2a901544cc3 100644
--- a/openpype/lib/remote_publish.py
+++ b/openpype/lib/remote_publish.py
@@ -66,7 +66,7 @@ def publish(log, close_plugin_name=None, raise_error=False):
     """Loops through all plugins, logs to console. Used for tests.
 
         Args:
-            log (OpenPypeLogger)
+            log (openpype.lib.Logger)
             close_plugin_name (str): name of plugin with responsibility to
                 close host app
     """
@@ -98,7 +98,7 @@ def publish_and_log(dbcon, _id, log, close_plugin_name=None, batch_id=None):
         Args:
             dbcon (OpenPypeMongoConnection)
             _id (str) - id of current job in DB
-            log (OpenPypeLogger)
+            log (openpype.lib.Logger)
             batch_id (str) - id sent from frontend
             close_plugin_name (str): name of plugin with responsibility to
                 close host app
diff --git a/openpype/modules/base.py b/openpype/modules/base.py
index 1316d7f734e..8ac4e7ddacc 100644
--- a/openpype/modules/base.py
+++ b/openpype/modules/base.py
@@ -13,7 +13,6 @@
 from abc import ABCMeta, abstractmethod
 import six
 
-import openpype
 from openpype.settings import (
     get_system_settings,
     SYSTEM_SETTINGS_KEY,
@@ -26,7 +25,12 @@
     get_studio_system_settings_overrides,
     load_json_file
 )
-from openpype.lib import PypeLogger
+
+from openpype.lib import (
+    Logger,
+    import_filepath,
+    import_module_from_dirpath
+)
 
 # Files that will be always ignored on modules import
 IGNORED_FILENAMES = (
@@ -93,7 +97,7 @@ def __getitem__(self, key):
     def log(self):
         if self._log is None:
             super(_ModuleClass, self).__setattr__(
-                "_log", PypeLogger.get_logger(self.name)
+                "_log", Logger.get_logger(self.name)
             )
         return self._log
 
@@ -278,19 +282,13 @@ def load_modules(force=False):
 
 
 def _load_modules():
-    # Import helper functions from lib
-    from openpype.lib import (
-        import_filepath,
-        import_module_from_dirpath
-    )
-
     # Key under which will be modules imported in `sys.modules`
     modules_key = "openpype_modules"
 
     # Change `sys.modules`
     sys.modules[modules_key] = openpype_modules = _ModuleClass(modules_key)
 
-    log = PypeLogger.get_logger("ModulesLoader")
+    log = Logger.get_logger("ModulesLoader")
 
     # Look for OpenPype modules in paths defined with `get_module_dirs`
     #   - dynamically imported OpenPype modules and addons
@@ -440,7 +438,7 @@ def name(self):
     def __init__(self, manager, settings):
         self.manager = manager
 
-        self.log = PypeLogger.get_logger(self.name)
+        self.log = Logger.get_logger(self.name)
 
         self.initialize(settings)
 
@@ -1059,7 +1057,7 @@ class TrayModulesManager(ModulesManager):
     )
 
     def __init__(self):
-        self.log = PypeLogger.get_logger(self.__class__.__name__)
+        self.log = Logger.get_logger(self.__class__.__name__)
 
         self.modules = []
         self.modules_by_id = {}
@@ -1235,7 +1233,7 @@ def get_module_settings_defs():
 
     settings_defs = []
 
-    log = PypeLogger.get_logger("ModuleSettingsLoad")
+    log = Logger.get_logger("ModuleSettingsLoad")
 
     for raw_module in openpype_modules:
         for attr_name in dir(raw_module):
diff --git a/openpype/modules/deadline/deadline_module.py b/openpype/modules/deadline/deadline_module.py
index c30db751885..bbd0f74e8a9 100644
--- a/openpype/modules/deadline/deadline_module.py
+++ b/openpype/modules/deadline/deadline_module.py
@@ -3,7 +3,7 @@
 import six
 import sys
 
-from openpype.lib import requests_get, PypeLogger
+from openpype.lib import requests_get, Logger
 from openpype.modules import OpenPypeModule
 from openpype_interfaces import IPluginPaths
 
@@ -58,7 +58,7 @@ def get_deadline_pools(webservice, log=None):
 
         """
         if not log:
-            log = PypeLogger.get_logger(__name__)
+            log = Logger.get_logger(__name__)
 
         argument = "{}/api/pools?NamesOnly=true".format(webservice)
         try:
diff --git a/openpype/modules/ftrack/ftrack_server/ftrack_server.py b/openpype/modules/ftrack/ftrack_server/ftrack_server.py
index 8944591b714..c75b8f71724 100644
--- a/openpype/modules/ftrack/ftrack_server/ftrack_server.py
+++ b/openpype/modules/ftrack/ftrack_server/ftrack_server.py
@@ -7,12 +7,10 @@
 import ftrack_api
 
 from openpype.lib import (
-    PypeLogger,
+    Logger,
     modules_from_path
 )
 
-log = PypeLogger.get_logger(__name__)
-
 """
 # Required - Needed for connection to Ftrack
 FTRACK_SERVER # Ftrack server e.g. "https://myFtrack.ftrackapp.com"
@@ -43,10 +41,13 @@ def __init__(self, handler_paths=None):
                 server.run_server()
                 ..
         """
+
         # set Ftrack logging to Warning only - OPTIONAL
         ftrack_log = logging.getLogger("ftrack_api")
         ftrack_log.setLevel(logging.WARNING)
 
+        self.log = Logger.get_logger(__name__)
+
         self.stopped = True
         self.is_running = False
 
@@ -72,7 +73,7 @@ def set_files(self, paths):
             # Get all modules with functions
             modules, crashed = modules_from_path(path)
             for filepath, exc_info in crashed:
-                log.warning("Filepath load crashed {}.\n{}".format(
+                self.log.warning("Filepath load crashed {}.\n{}".format(
                     filepath, traceback.format_exception(*exc_info)
                 ))
 
@@ -87,7 +88,7 @@ def set_files(self, paths):
                         break
 
                 if not register_function:
-                    log.warning(
+                    self.log.warning(
                         "\"{}\" - Missing register method".format(filepath)
                     )
                     continue
@@ -97,7 +98,7 @@ def set_files(self, paths):
                 )
 
         if not register_functions:
-            log.warning((
+            self.log.warning((
                 "There are no events with `register` function"
                 " in registered paths: \"{}\""
             ).format("| ".join(paths)))
@@ -106,7 +107,7 @@ def set_files(self, paths):
             try:
                 register_func(self.session)
             except Exception:
-                log.warning(
+                self.log.warning(
                     "\"{}\" - register was not successful".format(filepath),
                     exc_info=True
                 )
@@ -141,7 +142,7 @@ def run_server(self, session=None, load_files=True):
         self.session = session
         if load_files:
             if not self.handler_paths:
-                log.warning((
+                self.log.warning((
                     "Paths to event handlers are not set."
                     " Ftrack server won't launch."
                 ))
@@ -151,8 +152,8 @@ def run_server(self, session=None, load_files=True):
             self.set_files(self.handler_paths)
 
             msg = "Registration of event handlers has finished!"
-            log.info(len(msg) * "*")
-            log.info(msg)
+            self.log.info(len(msg) * "*")
+            self.log.info(msg)
 
         # keep event_hub on session running
         self.session.event_hub.wait()
diff --git a/openpype/modules/ftrack/ftrack_server/socket_thread.py b/openpype/modules/ftrack/ftrack_server/socket_thread.py
index f49ca5557e1..3ef55f8daae 100644
--- a/openpype/modules/ftrack/ftrack_server/socket_thread.py
+++ b/openpype/modules/ftrack/ftrack_server/socket_thread.py
@@ -5,8 +5,8 @@
 import threading
 import traceback
 import subprocess
-from openpype.api import Logger
-from openpype.lib import get_openpype_execute_args
+
+from openpype.lib import get_openpype_execute_args, Logger
 
 
 class SocketThread(threading.Thread):
@@ -16,7 +16,7 @@ class SocketThread(threading.Thread):
 
     def __init__(self, name, port, filepath, additional_args=[]):
         super(SocketThread, self).__init__()
-        self.log = Logger().get_logger(self.__class__.__name__)
+        self.log = Logger.get_logger(self.__class__.__name__)
         self.setName(name)
         self.name = name
         self.port = port
diff --git a/openpype/modules/ftrack/lib/ftrack_base_handler.py b/openpype/modules/ftrack/lib/ftrack_base_handler.py
index c0fad6aadc8..c0b03f8a417 100644
--- a/openpype/modules/ftrack/lib/ftrack_base_handler.py
+++ b/openpype/modules/ftrack/lib/ftrack_base_handler.py
@@ -6,7 +6,7 @@
 import datetime
 import traceback
 import time
-from openpype.api import Logger
+from openpype.lib import Logger
 from openpype.settings import get_project_settings
 
 import ftrack_api
@@ -52,7 +52,7 @@ def join_query_keys(keys):
 
     def __init__(self, session):
         '''Expects a ftrack_api.Session instance'''
-        self.log = Logger().get_logger(self.__class__.__name__)
+        self.log = Logger.get_logger(self.__class__.__name__)
         if not(
             isinstance(session, ftrack_api.session.Session) or
             isinstance(session, ftrack_server.lib.SocketSession)
diff --git a/openpype/modules/ftrack/scripts/sub_event_processor.py b/openpype/modules/ftrack/scripts/sub_event_processor.py
index d1e2e3aaeb2..a5ce0511b83 100644
--- a/openpype/modules/ftrack/scripts/sub_event_processor.py
+++ b/openpype/modules/ftrack/scripts/sub_event_processor.py
@@ -4,6 +4,8 @@
 import socket
 import datetime
 
+import ftrack_api
+
 from openpype_modules.ftrack.ftrack_server.ftrack_server import FtrackServer
 from openpype_modules.ftrack.ftrack_server.lib import (
     SocketSession,
@@ -12,17 +14,12 @@
 )
 from openpype.modules import ModulesManager
 
-from openpype.api import Logger
 from openpype.lib import (
+    Logger,
     get_openpype_version,
     get_build_version
 )
 
-
-import ftrack_api
-
-log = Logger().get_logger("Event processor")
-
 subprocess_started = datetime.datetime.now()
 
 
@@ -68,6 +65,8 @@ def register(session):
 
 
 def main(args):
+    log = Logger.get_logger("Event processor")
+
     port = int(args[-1])
     # Create a TCP/IP socket
     sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
diff --git a/openpype/modules/ftrack/scripts/sub_legacy_server.py b/openpype/modules/ftrack/scripts/sub_legacy_server.py
index e3a623c3763..1f0fc1b3698 100644
--- a/openpype/modules/ftrack/scripts/sub_legacy_server.py
+++ b/openpype/modules/ftrack/scripts/sub_legacy_server.py
@@ -5,11 +5,11 @@
 import threading
 
 import ftrack_api
-from openpype.api import Logger
+from openpype.lib import Logger
 from openpype.modules import ModulesManager
 from openpype_modules.ftrack.ftrack_server.ftrack_server import FtrackServer
 
-log = Logger().get_logger("Event Server Legacy")
+log = Logger.get_logger("Event Server Legacy")
 
 
 class TimerChecker(threading.Thread):
diff --git a/openpype/modules/ftrack/scripts/sub_user_server.py b/openpype/modules/ftrack/scripts/sub_user_server.py
index a3701a0950d..930a2d51e27 100644
--- a/openpype/modules/ftrack/scripts/sub_user_server.py
+++ b/openpype/modules/ftrack/scripts/sub_user_server.py
@@ -2,6 +2,7 @@
 import signal
 import socket
 
+from openpype.lib import Logger
 from openpype_modules.ftrack.ftrack_server.ftrack_server import FtrackServer
 from openpype_modules.ftrack.ftrack_server.lib import (
     SocketSession,
@@ -9,9 +10,7 @@
 )
 from openpype.modules import ModulesManager
 
-from openpype.api import Logger
-
-log = Logger().get_logger("FtrackUserServer")
+log = Logger.get_logger("FtrackUserServer")
 
 
 def main(args):
diff --git a/openpype/modules/ftrack/tray/ftrack_tray.py b/openpype/modules/ftrack/tray/ftrack_tray.py
index 2919ae22fb9..501d837a4c4 100644
--- a/openpype/modules/ftrack/tray/ftrack_tray.py
+++ b/openpype/modules/ftrack/tray/ftrack_tray.py
@@ -12,10 +12,11 @@
 from ..ftrack_module import FTRACK_MODULE_DIR
 from . import login_dialog
 
-from openpype.api import Logger, resources
+from openpype import resources
+from openpype.lib import Logger
 
 
-log = Logger().get_logger("FtrackModule")
+log = Logger.get_logger("FtrackModule")
 
 
 class FtrackTrayWrapper:
diff --git a/openpype/modules/log_viewer/tray/models.py b/openpype/modules/log_viewer/tray/models.py
index aea62c381b3..d369ffeb64d 100644
--- a/openpype/modules/log_viewer/tray/models.py
+++ b/openpype/modules/log_viewer/tray/models.py
@@ -1,6 +1,6 @@
 import collections
 from Qt import QtCore, QtGui
-from openpype.lib.log import PypeLogger
+from openpype.lib import Logger
 
 
 class LogModel(QtGui.QStandardItemModel):
@@ -41,14 +41,14 @@ def __init__(self, parent=None):
         self.dbcon = None
 
         # Crash if connection is not possible to skip this module
-        if not PypeLogger.initialized:
-            PypeLogger.initialize()
+        if not Logger.initialized:
+            Logger.initialize()
 
-        connection = PypeLogger.get_log_mongo_connection()
+        connection = Logger.get_log_mongo_connection()
         if connection:
-            PypeLogger.bootstrap_mongo_log()
-            database = connection[PypeLogger.log_database_name]
-            self.dbcon = database[PypeLogger.log_collection_name]
+            Logger.bootstrap_mongo_log()
+            database = connection[Logger.log_database_name]
+            self.dbcon = database[Logger.log_collection_name]
 
     def headerData(self, section, orientation, role):
         if (
diff --git a/openpype/modules/royalrender/api.py b/openpype/modules/royalrender/api.py
index ed9e71f2404..de1dba8724b 100644
--- a/openpype/modules/royalrender/api.py
+++ b/openpype/modules/royalrender/api.py
@@ -5,13 +5,10 @@
 
 from openpype.settings import get_project_settings
 from openpype.lib.local_settings import OpenPypeSettingsRegistry
-from openpype.lib import PypeLogger, run_subprocess
+from openpype.lib import Logger, run_subprocess
 from .rr_job import RRJob, SubmitFile, SubmitterParameter
 
 
-log = PypeLogger.get_logger("RoyalRender")
-
-
 class Api:
 
     _settings = None
@@ -19,6 +16,7 @@ class Api:
     RR_SUBMIT_API = 2
 
     def __init__(self, settings, project=None):
+        self.log = Logger.get_logger("RoyalRender")
         self._settings = settings
         self._initialize_rr(project)
 
@@ -137,7 +135,7 @@ def _submit_using_console(self, file):
             rr_console += ".exe"
 
         args = [rr_console, file]
-        run_subprocess(" ".join(args), logger=log)
+        run_subprocess(" ".join(args), logger=self.log)
 
     def _submit_using_api(self, file):
         # type: (SubmitFile) -> None
@@ -159,11 +157,11 @@ def _submit_using_api(self, file):
         rr_server = tcp.getRRServer()
 
         if len(rr_server) == 0:
-            log.info("Got RR IP address {}".format(rr_server))
+            self.log.info("Got RR IP address {}".format(rr_server))
 
         # TODO: Port is hardcoded in RR? If not, move it to Settings
         if not tcp.setServer(rr_server, 7773):
-            log.error(
+            self.log.error(
                 "Can not set RR server: {}".format(tcp.errorMessage()))
             raise RoyalRenderException(tcp.errorMessage())
 
diff --git a/openpype/modules/sync_server/providers/abstract_provider.py b/openpype/modules/sync_server/providers/abstract_provider.py
index 8c2fe1cad93..9c808dc80ef 100644
--- a/openpype/modules/sync_server/providers/abstract_provider.py
+++ b/openpype/modules/sync_server/providers/abstract_provider.py
@@ -1,8 +1,8 @@
 import abc
 import six
-from openpype.api import Logger
+from openpype.lib import Logger
 
-log = Logger().get_logger("SyncServer")
+log = Logger.get_logger("SyncServer")
 
 
 @six.add_metaclass(abc.ABCMeta)
diff --git a/openpype/modules/sync_server/sync_server.py b/openpype/modules/sync_server/sync_server.py
index 97538fcd4e1..8b11055e655 100644
--- a/openpype/modules/sync_server/sync_server.py
+++ b/openpype/modules/sync_server/sync_server.py
@@ -6,14 +6,11 @@
 from concurrent.futures._base import CancelledError
 
 from .providers import lib
-from openpype.lib import PypeLogger
+from openpype.lib import Logger
 
 from .utils import SyncStatus, ResumableError
 
 
-log = PypeLogger().get_logger("SyncServer")
-
-
 async def upload(module, project_name, file, representation, provider_name,
                  remote_site_name, tree=None, preset=None):
     """
@@ -238,6 +235,7 @@ class SyncServerThread(threading.Thread):
         Stopped when tray is closed.
     """
     def __init__(self, module):
+        self.log = Logger.get_logger(self.__class__.__name__)
         super(SyncServerThread, self).__init__()
         self.module = module
         self.loop = None
@@ -249,17 +247,17 @@ def run(self):
         self.is_running = True
 
         try:
-            log.info("Starting Sync Server")
+            self.log.info("Starting Sync Server")
             self.loop = asyncio.new_event_loop()  # create new loop for thread
             asyncio.set_event_loop(self.loop)
             self.loop.set_default_executor(self.executor)
 
             asyncio.ensure_future(self.check_shutdown(), loop=self.loop)
             asyncio.ensure_future(self.sync_loop(), loop=self.loop)
-            log.info("Sync Server Started")
+            self.log.info("Sync Server Started")
             self.loop.run_forever()
         except Exception:
-            log.warning(
+            self.log.warning(
                 "Sync Server service has failed", exc_info=True
             )
         finally:
@@ -379,8 +377,9 @@ async def sync_loop(self):
                                                                  ))
                                     processed_file_path.add(file_path)
 
-                    log.debug("Sync tasks count {}".
-                              format(len(task_files_to_process)))
+                    self.log.debug("Sync tasks count {}".format(
+                        len(task_files_to_process)
+                    ))
                     files_created = await asyncio.gather(
                         *task_files_to_process,
                         return_exceptions=True)
@@ -399,28 +398,31 @@ async def sync_loop(self):
                                               error)
 
                 duration = time.time() - start_time
-                log.debug("One loop took {:.2f}s".format(duration))
+                self.log.debug("One loop took {:.2f}s".format(duration))
 
                 delay = self.module.get_loop_delay(project_name)
-                log.debug("Waiting for {} seconds to new loop".format(delay))
+                self.log.debug(
+                    "Waiting for {} seconds to new loop".format(delay)
+                )
                 self.timer = asyncio.create_task(self.run_timer(delay))
                 await asyncio.gather(self.timer)
 
             except ConnectionResetError:
-                log.warning("ConnectionResetError in sync loop, "
-                            "trying next loop",
-                            exc_info=True)
+                self.log.warning(
+                    "ConnectionResetError in sync loop, trying next loop",
+                    exc_info=True)
             except CancelledError:
                 # just stopping server
                 pass
             except ResumableError:
-                log.warning("ResumableError in sync loop, "
-                            "trying next loop",
-                            exc_info=True)
+                self.log.warning(
+                    "ResumableError in sync loop, trying next loop",
+                    exc_info=True)
             except Exception:
                 self.stop()
-                log.warning("Unhandled except. in sync loop, stopping server",
-                            exc_info=True)
+                self.log.warning(
+                    "Unhandled except. in sync loop, stopping server",
+                    exc_info=True)
 
     def stop(self):
         """Sets is_running flag to false, 'check_shutdown' shuts server down"""
@@ -433,16 +435,17 @@ async def check_shutdown(self):
         while self.is_running:
             if self.module.long_running_tasks:
                 task = self.module.long_running_tasks.pop()
-                log.info("starting long running")
+                self.log.info("starting long running")
                 await self.loop.run_in_executor(None, task["func"])
-                log.info("finished long running")
+                self.log.info("finished long running")
                 self.module.projects_processed.remove(task["project_name"])
             await asyncio.sleep(0.5)
         tasks = [task for task in asyncio.all_tasks() if
                  task is not asyncio.current_task()]
         list(map(lambda task: task.cancel(), tasks))  # cancel all the tasks
         results = await asyncio.gather(*tasks, return_exceptions=True)
-        log.debug(f'Finished awaiting cancelled tasks, results: {results}...')
+        self.log.debug(
+            f'Finished awaiting cancelled tasks, results: {results}...')
         await self.loop.shutdown_asyncgens()
         # to really make sure everything else has time to stop
         self.executor.shutdown(wait=True)
@@ -455,29 +458,32 @@ async def run_timer(self, delay):
 
     def reset_timer(self):
         """Called when waiting for next loop should be skipped"""
-        log.debug("Resetting timer")
+        self.log.debug("Resetting timer")
         if self.timer:
             self.timer.cancel()
             self.timer = None
 
     def _working_sites(self, project_name):
         if self.module.is_project_paused(project_name):
-            log.debug("Both sites same, skipping")
+            self.log.debug("Both sites same, skipping")
             return None, None
 
         local_site = self.module.get_active_site(project_name)
         remote_site = self.module.get_remote_site(project_name)
         if local_site == remote_site:
-            log.debug("{}-{} sites same, skipping".format(local_site,
-                                                          remote_site))
+            self.log.debug("{}-{} sites same, skipping".format(
+                local_site, remote_site))
             return None, None
 
         configured_sites = _get_configured_sites(self.module, project_name)
         if not all([local_site in configured_sites,
                     remote_site in configured_sites]):
-            log.debug("Some of the sites {} - {} is not ".format(local_site,
-                                                                 remote_site) +
-                      "working properly")
+            self.log.debug(
+                "Some of the sites {} - {} is not working properly".format(
+                    local_site, remote_site
+                )
+            )
+
             return None, None
 
         return local_site, remote_site
diff --git a/openpype/modules/sync_server/sync_server_module.py b/openpype/modules/sync_server/sync_server_module.py
index c7f9484e55d..634b68c55f0 100644
--- a/openpype/modules/sync_server/sync_server_module.py
+++ b/openpype/modules/sync_server/sync_server_module.py
@@ -13,7 +13,7 @@
     get_project_settings,
     get_system_settings,
 )
-from openpype.lib import PypeLogger, get_local_site_id
+from openpype.lib import Logger, get_local_site_id
 from openpype.pipeline import AvalonMongoDB, Anatomy
 from openpype.settings.lib import (
     get_default_anatomy_settings,
@@ -28,7 +28,7 @@
 from openpype.client import get_representations, get_representation_by_id
 
 
-log = PypeLogger.get_logger("SyncServer")
+log = Logger.get_logger("SyncServer")
 
 
 class SyncServerModule(OpenPypeModule, ITrayModule):
@@ -462,7 +462,7 @@ def pause_representation(self, project_name, representation_id, site_name):
                 representation_id (string): MongoDB objectId value
                 site_name (string): 'gdrive', 'studio' etc.
         """
-        log.info("Pausing SyncServer for {}".format(representation_id))
+        self.log.info("Pausing SyncServer for {}".format(representation_id))
         self._paused_representations.add(representation_id)
         self.reset_site_on_representation(project_name, representation_id,
                                           site_name=site_name, pause=True)
@@ -479,7 +479,7 @@ def unpause_representation(self, project_name,
                 representation_id (string): MongoDB objectId value
                 site_name (string): 'gdrive', 'studio' etc.
         """
-        log.info("Unpausing SyncServer for {}".format(representation_id))
+        self.log.info("Unpausing SyncServer for {}".format(representation_id))
         try:
             self._paused_representations.remove(representation_id)
         except KeyError:
@@ -518,7 +518,7 @@ def pause_project(self, project_name):
             Args:
                 project_name (string): project_name name
         """
-        log.info("Pausing SyncServer for {}".format(project_name))
+        self.log.info("Pausing SyncServer for {}".format(project_name))
         self._paused_projects.add(project_name)
 
     def unpause_project(self, project_name):
@@ -530,7 +530,7 @@ def unpause_project(self, project_name):
             Args:
                 project_name (string):
         """
-        log.info("Unpausing SyncServer for {}".format(project_name))
+        self.log.info("Unpausing SyncServer for {}".format(project_name))
         try:
             self._paused_projects.remove(project_name)
         except KeyError:
@@ -558,14 +558,14 @@ def pause_server(self):
 
             It won't check anything, not uploading/downloading...
         """
-        log.info("Pausing SyncServer")
+        self.log.info("Pausing SyncServer")
         self._paused = True
 
     def unpause_server(self):
         """
             Unpause server
         """
-        log.info("Unpausing SyncServer")
+        self.log.info("Unpausing SyncServer")
         self._paused = False
 
     def is_paused(self):
@@ -876,7 +876,7 @@ def get_local_settings_schema(cls):
     #                             val = val[platform.system().lower()]
     #                     except KeyError:
     #                         st = "{}'s field value {} should be".format(key, val)  # noqa: E501
-    #                         log.error(st + " multiplatform dict")
+    #                         self.log.error(st + " multiplatform dict")
     #
     #                 item["namespace"] = item["namespace"].replace('{site}',
     #                                                               site_name)
@@ -1148,7 +1148,7 @@ def server_start(self):
         if self.enabled:
             self.sync_server_thread.start()
         else:
-            log.info("No presets or active providers. " +
+            self.log.info("No presets or active providers. " +
                      "Synchronization not possible.")
 
     def tray_exit(self):
@@ -1166,12 +1166,12 @@ def server_exit(self):
         if not self.is_running:
             return
         try:
-            log.info("Stopping sync server server")
+            self.log.info("Stopping sync server server")
             self.sync_server_thread.is_running = False
             self.sync_server_thread.stop()
-            log.info("Sync server stopped")
+            self.log.info("Sync server stopped")
         except Exception:
-            log.warning(
+            self.log.warning(
                 "Error has happened during Killing sync server",
                 exc_info=True
             )
@@ -1256,7 +1256,7 @@ def _prepare_sync_project_settings(self, exclude_locals):
 
             sync_project_settings[project_name] = proj_settings
         if not sync_project_settings:
-            log.info("No enabled and configured projects for sync.")
+            self.log.info("No enabled and configured projects for sync.")
         return sync_project_settings
 
     def get_sync_project_setting(self, project_name, exclude_locals=False,
@@ -1387,7 +1387,7 @@ def get_sync_representations(self, project_name, active_site, remote_site):
         Returns:
             (list) of dictionaries
         """
-        log.debug("Check representations for : {}".format(project_name))
+        self.log.debug("Check representations for : {}".format(project_name))
         self.connection.Session["AVALON_PROJECT"] = project_name
         # retry_cnt - number of attempts to sync specific file before giving up
         retries_arr = self._get_retries_arr(project_name)
@@ -1466,9 +1466,10 @@ def get_sync_representations(self, project_name, active_site, remote_site):
             }},
             {"$sort": {'priority': -1, '_id': 1}},
         ]
-        log.debug("active_site:{} - remote_site:{}".format(active_site,
-                                                           remote_site))
-        log.debug("query: {}".format(aggr))
+        self.log.debug("active_site:{} - remote_site:{}".format(
+            active_site, remote_site
+        ))
+        self.log.debug("query: {}".format(aggr))
         representations = self.connection.aggregate(aggr)
 
         return representations
@@ -1503,7 +1504,9 @@ def check_status(self, file, local_site, remote_site, config_preset):
 
         if get_local_site_id() not in (local_site, remote_site):
             # don't do upload/download for studio sites
-            log.debug("No local site {} - {}".format(local_site, remote_site))
+            self.log.debug(
+                "No local site {} - {}".format(local_site, remote_site)
+            )
             return SyncStatus.DO_NOTHING
 
         _, remote_rec = self._get_site_rec(sites, remote_site) or {}
@@ -1594,11 +1597,16 @@ def update_db(self, project_name, new_file_id, file, representation,
             error_str = ''
 
         source_file = file.get("path", "")
-        log.debug("File for {} - {source_file} process {status} {error_str}".
-                  format(representation_id,
-                         status=status,
-                         source_file=source_file,
-                         error_str=error_str))
+        self.log.debug(
+            (
+                "File for {} - {source_file} process {status} {error_str}"
+            ).format(
+                representation_id,
+                status=status,
+                source_file=source_file,
+                error_str=error_str
+            )
+        )
 
     def _get_file_info(self, files, _id):
         """
@@ -1772,7 +1780,7 @@ def _remove_site(self, project_name, representation, site_name):
                     break
         if not found:
             msg = "Site {} not found".format(site_name)
-            log.info(msg)
+            self.log.info(msg)
             raise ValueError(msg)
 
         update = {
@@ -1799,7 +1807,7 @@ def _pause_unpause_site(self, project_name, representation,
                     break
         if not found:
             msg = "Site {} not found".format(site_name)
-            log.info(msg)
+            self.log.info(msg)
             raise ValueError(msg)
 
         if pause:
@@ -1834,7 +1842,7 @@ def _add_site(self, project_name, representation, elem, site_name,
         reset_existing = False
         files = representation.get("files", [])
         if not files:
-            log.debug("No files for {}".format(representation_id))
+            self.log.debug("No files for {}".format(representation_id))
             return
 
         for repre_file in files:
@@ -1851,7 +1859,7 @@ def _add_site(self, project_name, representation, elem, site_name,
                         reset_existing = True
                     else:
                         msg = "Site {} already present".format(site_name)
-                        log.info(msg)
+                        self.log.info(msg)
                         raise SiteAlreadyPresentError(msg)
 
         if reset_existing:
@@ -1951,16 +1959,19 @@ def show_widget(self):
             self.widget = SyncServerWindow(self)
             no_errors = True
         except ValueError:
-            log.info("No system setting for sync. Not syncing.", exc_info=True)
+            self.log.info(
+                "No system setting for sync. Not syncing.", exc_info=True
+            )
         except KeyError:
-            log.info((
+            self.log.info((
                 "There are not set presets for SyncServer OR "
                 "Credentials provided are invalid, "
                 "no syncing possible").
                 format(str(self.sync_project_settings)), exc_info=True)
         except:
-            log.error("Uncaught exception durin start of SyncServer",
-                      exc_info=True)
+            self.log.error(
+                "Uncaught exception durin start of SyncServer",
+                exc_info=True)
         self.enabled = no_errors
         self.widget.show()
 
diff --git a/openpype/modules/sync_server/tray/app.py b/openpype/modules/sync_server/tray/app.py
index 96fad6a2472..9b9768327ec 100644
--- a/openpype/modules/sync_server/tray/app.py
+++ b/openpype/modules/sync_server/tray/app.py
@@ -2,7 +2,6 @@
 
 from openpype.tools.settings import style
 
-from openpype.lib import PypeLogger
 from openpype import resources
 
 from .widgets import (
@@ -10,8 +9,6 @@
     SyncRepresentationSummaryWidget
 )
 
-log = PypeLogger().get_logger("SyncServer")
-
 
 class SyncServerWindow(QtWidgets.QDialog):
     """
diff --git a/openpype/modules/sync_server/tray/delegates.py b/openpype/modules/sync_server/tray/delegates.py
index 5ab809a8166..988eb40d28e 100644
--- a/openpype/modules/sync_server/tray/delegates.py
+++ b/openpype/modules/sync_server/tray/delegates.py
@@ -1,8 +1,7 @@
 import os
 from Qt import QtCore, QtWidgets, QtGui
 
-from openpype.lib import PypeLogger
-from . import lib
+from openpype.lib import Logger
 
 from openpype.tools.utils.constants import (
     LOCAL_PROVIDER_ROLE,
@@ -16,7 +15,7 @@
     EDIT_ICON_ROLE
 )
 
-log = PypeLogger().get_logger("SyncServer")
+log = Logger.get_logger("SyncServer")
 
 
 class PriorityDelegate(QtWidgets.QStyledItemDelegate):
diff --git a/openpype/modules/sync_server/tray/lib.py b/openpype/modules/sync_server/tray/lib.py
index 87344be634d..ff93815639d 100644
--- a/openpype/modules/sync_server/tray/lib.py
+++ b/openpype/modules/sync_server/tray/lib.py
@@ -2,11 +2,6 @@
 import abc
 import six
 
-from openpype.lib import PypeLogger
-
-
-log = PypeLogger().get_logger("SyncServer")
-
 STATUS = {
     0: 'In Progress',
     1: 'Queued',
diff --git a/openpype/modules/sync_server/tray/models.py b/openpype/modules/sync_server/tray/models.py
index 629c4cbbf12..d63d046508e 100644
--- a/openpype/modules/sync_server/tray/models.py
+++ b/openpype/modules/sync_server/tray/models.py
@@ -9,8 +9,7 @@
 
 from openpype.tools.utils.delegates import pretty_timestamp
 
-from openpype.lib import PypeLogger
-from openpype.api import get_local_site_id
+from openpype.lib import Logger, get_local_site_id
 from openpype.client import get_representation_by_id
 
 from . import lib
@@ -33,7 +32,7 @@
 )
 
 
-log = PypeLogger().get_logger("SyncServer")
+log = Logger.get_logger("SyncServer")
 
 
 class _SyncRepresentationModel(QtCore.QAbstractTableModel):
diff --git a/openpype/modules/sync_server/tray/widgets.py b/openpype/modules/sync_server/tray/widgets.py
index b4ee447ac4c..c40aa98f248 100644
--- a/openpype/modules/sync_server/tray/widgets.py
+++ b/openpype/modules/sync_server/tray/widgets.py
@@ -9,8 +9,7 @@
 
 from openpype.tools.settings import style
 
-from openpype.api import get_local_site_id
-from openpype.lib import PypeLogger
+from openpype.lib import Logger, get_local_site_id
 
 from openpype.tools.utils.delegates import pretty_timestamp
 
@@ -36,7 +35,7 @@
     TRIES_ROLE
 )
 
-log = PypeLogger().get_logger("SyncServer")
+log = Logger.get_logger("SyncServer")
 
 
 class SyncProjectListWidget(QtWidgets.QWidget):
diff --git a/openpype/modules/sync_server/utils.py b/openpype/modules/sync_server/utils.py
index 03f362202f6..4caa01e9d73 100644
--- a/openpype/modules/sync_server/utils.py
+++ b/openpype/modules/sync_server/utils.py
@@ -1,6 +1,8 @@
 import time
-from openpype.api import Logger
-log = Logger().get_logger("SyncServer")
+
+from openpype.lib import Logger
+
+log = Logger.get_logger("SyncServer")
 
 
 class ResumableError(Exception):
diff --git a/openpype/modules/timers_manager/idle_threads.py b/openpype/modules/timers_manager/idle_threads.py
index 9ec27e659be..72427611432 100644
--- a/openpype/modules/timers_manager/idle_threads.py
+++ b/openpype/modules/timers_manager/idle_threads.py
@@ -2,7 +2,7 @@
 from Qt import QtCore
 from pynput import mouse, keyboard
 
-from openpype.lib import PypeLogger
+from openpype.lib import Logger
 
 
 class IdleItem:
@@ -31,7 +31,7 @@ class IdleManager(QtCore.QThread):
 
     def __init__(self):
         super(IdleManager, self).__init__()
-        self.log = PypeLogger.get_logger(self.__class__.__name__)
+        self.log = Logger.get_logger(self.__class__.__name__)
         self.signal_reset_timer.connect(self._reset_time)
 
         self.idle_item = IdleItem()
diff --git a/openpype/modules/timers_manager/rest_api.py b/openpype/modules/timers_manager/rest_api.py
index f16cb316c3d..66864073503 100644
--- a/openpype/modules/timers_manager/rest_api.py
+++ b/openpype/modules/timers_manager/rest_api.py
@@ -1,9 +1,7 @@
 import json
 
 from aiohttp.web_response import Response
-from openpype.api import Logger
-
-log = Logger().get_logger("Event processor")
+from openpype.lib import Logger
 
 
 class TimersManagerModuleRestApi:
@@ -12,6 +10,7 @@ class TimersManagerModuleRestApi:
         happens in Workfile app.
     """
     def __init__(self, user_module, server_manager):
+        self.log = None
         self.module = user_module
         self.server_manager = server_manager
 
@@ -19,6 +18,12 @@ def __init__(self, user_module, server_manager):
 
         self.register()
 
+    @property
+    def log(self):
+        if self._log is None:
+            self._log = Logger.get_logger(self.__ckass__.__name__)
+        return self._log
+
     def register(self):
         self.server_manager.add_route(
             "POST",
@@ -47,7 +52,7 @@ async def start_timer(self, request):
                 "Payload must contain fields 'project_name,"
                 " 'asset_name' and 'task_name'"
             )
-            log.error(msg)
+            self.log.error(msg)
             return Response(status=400, message=msg)
 
         self.module.stop_timers()
@@ -73,7 +78,7 @@ async def get_task_time(self, request):
                 "Payload must contain fields 'project_name, 'asset_name',"
                 " 'task_name'"
             )
-            log.warning(message)
+            self.log.warning(message)
             return Response(text=message, status=404)
 
         time = self.module.get_task_time(project_name, asset_name, task_name)
diff --git a/openpype/modules/webserver/server.py b/openpype/modules/webserver/server.py
index 82b681f4066..120925a362e 100644
--- a/openpype/modules/webserver/server.py
+++ b/openpype/modules/webserver/server.py
@@ -4,16 +4,16 @@
 
 from aiohttp import web
 
-from openpype.lib import PypeLogger
+from openpype.lib import Logger
 from .cors_middleware import cors_middleware
 
-log = PypeLogger.get_logger("WebServer")
-
 
 class WebServerManager:
     """Manger that care about web server thread."""
 
     def __init__(self, port=None, host=None):
+        self._log = None
+
         self.port = port or 8079
         self.host = host or "localhost"
 
@@ -33,6 +33,12 @@ def __init__(self, port=None, host=None):
 
         self.webserver_thread = WebServerThread(self)
 
+    @property
+    def log(self):
+        if self._log is None:
+            self._log = Logger.get_logger(self.__class__.__name__)
+        return self._log
+
     @property
     def url(self):
         return "http://{}:{}".format(self.host, self.port)
@@ -51,12 +57,12 @@ def stop_server(self):
         if not self.is_running:
             return
         try:
-            log.debug("Stopping Web server")
+            self.log.debug("Stopping Web server")
             self.webserver_thread.is_running = False
             self.webserver_thread.stop()
 
         except Exception:
-            log.warning(
+            self.log.warning(
                 "Error has happened during Killing Web server",
                 exc_info=True
             )
@@ -74,7 +80,10 @@ def thread_stopped(self):
 
 class WebServerThread(threading.Thread):
     """ Listener for requests in thread."""
+
     def __init__(self, manager):
+        self._log = None
+
         super(WebServerThread, self).__init__()
 
         self.is_running = False
@@ -84,6 +93,12 @@ def __init__(self, manager):
         self.site = None
         self.tasks = []
 
+    @property
+    def log(self):
+        if self._log is None:
+            self._log = Logger.get_logger(self.__class__.__name__)
+        return self._log
+
     @property
     def port(self):
         return self.manager.port
@@ -96,13 +111,13 @@ def run(self):
         self.is_running = True
 
         try:
-            log.info("Starting WebServer server")
+            self.log.info("Starting WebServer server")
             self.loop = asyncio.new_event_loop()  # create new loop for thread
             asyncio.set_event_loop(self.loop)
 
             self.loop.run_until_complete(self.start_server())
 
-            log.debug(
+            self.log.debug(
                 "Running Web server on URL: \"localhost:{}\"".format(self.port)
             )
 
@@ -110,7 +125,7 @@ def run(self):
             self.loop.run_forever()
 
         except Exception:
-            log.warning(
+            self.log.warning(
                 "Web Server service has failed", exc_info=True
             )
         finally:
@@ -118,7 +133,7 @@ def run(self):
 
         self.is_running = False
         self.manager.thread_stopped()
-        log.info("Web server stopped")
+        self.log.info("Web server stopped")
 
     async def start_server(self):
         """ Starts runner and TCPsite """
@@ -138,17 +153,17 @@ async def check_shutdown(self):
         while self.is_running:
             while self.tasks:
                 task = self.tasks.pop(0)
-                log.debug("waiting for task {}".format(task))
+                self.log.debug("waiting for task {}".format(task))
                 await task
-                log.debug("returned value {}".format(task.result))
+                self.log.debug("returned value {}".format(task.result))
 
             await asyncio.sleep(0.5)
 
-        log.debug("Starting shutdown")
+        self.log.debug("Starting shutdown")
         await self.site.stop()
-        log.debug("Site stopped")
+        self.log.debug("Site stopped")
         await self.runner.cleanup()
-        log.debug("Runner stopped")
+        self.log.debug("Runner stopped")
         tasks = [
             task
             for task in asyncio.all_tasks()
@@ -156,7 +171,9 @@ async def check_shutdown(self):
         ]
         list(map(lambda task: task.cancel(), tasks))  # cancel all the tasks
         results = await asyncio.gather(*tasks, return_exceptions=True)
-        log.debug(f'Finished awaiting cancelled tasks, results: {results}...')
+        self.log.debug(
+            f'Finished awaiting cancelled tasks, results: {results}...'
+        )
         await self.loop.shutdown_asyncgens()
         # to really make sure everything else has time to stop
         await asyncio.sleep(0.07)
diff --git a/openpype/pipeline/anatomy.py b/openpype/pipeline/anatomy.py
index 08db4749b34..cb6e07154b8 100644
--- a/openpype/pipeline/anatomy.py
+++ b/openpype/pipeline/anatomy.py
@@ -14,9 +14,9 @@
     TemplatesDict,
     FormatObject,
 )
-from openpype.lib.log import PypeLogger
+from openpype.lib.log import Logger
 
-log = PypeLogger.get_logger(__name__)
+log = Logger.get_logger(__name__)
 
 
 class ProjectNotSet(Exception):
diff --git a/openpype/pype_commands.py b/openpype/pype_commands.py
index 66bf5e9bb48..71fa7fb6c08 100644
--- a/openpype/pype_commands.py
+++ b/openpype/pype_commands.py
@@ -5,7 +5,6 @@
 import json
 import time
 
-from openpype.lib import PypeLogger
 from openpype.api import get_app_environments_for_context
 from openpype.lib.plugin_tools import get_batch_asset_task_info
 from openpype.lib.remote_publish import (
@@ -27,10 +26,11 @@ class PypeCommands:
     """
     @staticmethod
     def launch_tray():
-        PypeLogger.set_process_name("Tray")
-
+        from openpype.lib import Logger
         from openpype.tools import tray
 
+        Logger.set_process_name("Tray")
+
         tray.main()
 
     @staticmethod
@@ -47,10 +47,12 @@ def launch_settings_gui(dev):
     @staticmethod
     def add_modules(click_func):
         """Modules/Addons can add their cli commands dynamically."""
+
+        from openpype.lib import Logger
         from openpype.modules import ModulesManager
 
         manager = ModulesManager()
-        log = PypeLogger.get_logger("AddModulesCLI")
+        log = Logger.get_logger("CLI-AddModules")
         for module in manager.modules:
             try:
                 module.cli(click_func)
@@ -96,10 +98,10 @@ def publish(paths, targets=None, gui=False):
         Raises:
             RuntimeError: When there is no path to process.
         """
+
+        from openpype.lib import Logger
         from openpype.modules import ModulesManager
         from openpype.pipeline import install_openpype_plugins
-
-        from openpype.api import Logger
         from openpype.tools.utils.host_tools import show_publish
         from openpype.tools.utils.lib import qt_app_context
 
@@ -107,7 +109,7 @@ def publish(paths, targets=None, gui=False):
         import pyblish.api
         import pyblish.util
 
-        log = Logger.get_logger()
+        log = Logger.get_logger("CLI-publish")
 
         install_openpype_plugins()
 
@@ -195,11 +197,12 @@ def remotepublishfromapp(project_name, batch_path, host_name,
             targets (list): Pyblish targets
                 (to choose validator for example)
         """
+
         import pyblish.api
-        from openpype.api import Logger
         from openpype.lib import ApplicationManager
 
-        log = Logger.get_logger()
+        from openpype.lib import Logger
+        log = Logger.get_logger("CLI-remotepublishfromapp")
 
         log.info("remotepublishphotoshop command")
 
@@ -311,10 +314,11 @@ def remotepublish(project, batch_path, user_email, targets=None):
         import pyblish.api
         import pyblish.util
 
+        from openpype.lib import Logger
         from openpype.pipeline import install_host
         from openpype.hosts.webpublisher import api as webpublisher
 
-        log = PypeLogger.get_logger()
+        log = Logger.get_logger("remotepublish")
 
         log.info("remotepublish command")
 
diff --git a/openpype/settings/entities/base_entity.py b/openpype/settings/entities/base_entity.py
index 741f13c49b8..f28fefdf5a8 100644
--- a/openpype/settings/entities/base_entity.py
+++ b/openpype/settings/entities/base_entity.py
@@ -15,7 +15,7 @@
     EntitySchemaError
 )
 
-from openpype.lib import PypeLogger
+from openpype.lib import Logger
 
 
 @six.add_metaclass(ABCMeta)
@@ -478,7 +478,7 @@ def user_role(self):
     def log(self):
         """Auto created logger for debugging or warnings."""
         if self._log is None:
-            self._log = PypeLogger.get_logger(self.__class__.__name__)
+            self._log = Logger.get_logger(self.__class__.__name__)
         return self._log
 
     @abstractproperty