from openstack.common.gettextutils import _
 from openstack.common import jsonutils
 from openstack.common import local
-from openstack.common import notifier
+from openstack.common.notifier import notifier_api


 log_opts = [
@@ -251,9 +251,9 @@ class PublishErrorsHandler(logging.Handler):
             if ('openstack.common.notifier.log_notifier' in
                 CONF.list_notifier_drivers):
                 return
-        notifier.api.notify(None, 'error.publisher',
+        notifier_api.notify(None, 'error.publisher',
                                  'error_notification',
-                                 notifier.api.ERROR,
+                                 notifier_api.ERROR,
                                  dict(error=record.msg))