Trivial: Remove unused logging import
Change-Id: Ic8cb2b5a45ac0e49c34c3903a52a3d22a7bcb45d
This commit is contained in:
parent
7aa6856f6c
commit
7aa7a880c5
|
@ -24,7 +24,6 @@ uses AMQP, but is deprecated and predates this code.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
import collections
|
import collections
|
||||||
import logging
|
|
||||||
import uuid
|
import uuid
|
||||||
|
|
||||||
from oslo_config import cfg
|
from oslo_config import cfg
|
||||||
|
@ -51,7 +50,6 @@ amqp_opts = [
|
||||||
]
|
]
|
||||||
|
|
||||||
UNIQUE_ID = '_unique_id'
|
UNIQUE_ID = '_unique_id'
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class RpcContext(rpc_common.CommonRpcContext):
|
class RpcContext(rpc_common.CommonRpcContext):
|
||||||
|
|
|
@ -12,7 +12,6 @@
|
||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
import os
|
import os
|
||||||
import socket
|
import socket
|
||||||
import threading
|
import threading
|
||||||
|
@ -29,7 +28,6 @@ from oslo_messaging._executors import impl_pooledexecutor
|
||||||
from oslo_messaging._i18n import _LE
|
from oslo_messaging._i18n import _LE
|
||||||
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
RPCException = rpc_common.RPCException
|
RPCException = rpc_common.RPCException
|
||||||
|
|
||||||
zmq_opts = [
|
zmq_opts = [
|
||||||
|
|
|
@ -13,14 +13,11 @@
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import abc
|
import abc
|
||||||
import logging
|
|
||||||
|
|
||||||
import six
|
import six
|
||||||
|
|
||||||
from oslo_messaging._drivers.zmq_driver import zmq_async
|
from oslo_messaging._drivers.zmq_driver import zmq_async
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
@six.add_metaclass(abc.ABCMeta)
|
@six.add_metaclass(abc.ABCMeta)
|
||||||
class BaseProxy(object):
|
class BaseProxy(object):
|
||||||
|
|
|
@ -13,16 +13,12 @@
|
||||||
|
|
||||||
import abc
|
import abc
|
||||||
import collections
|
import collections
|
||||||
import logging
|
|
||||||
|
|
||||||
import six
|
import six
|
||||||
|
|
||||||
from oslo_messaging._drivers.zmq_driver import zmq_address
|
from oslo_messaging._drivers.zmq_driver import zmq_address
|
||||||
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
@six.add_metaclass(abc.ABCMeta)
|
@six.add_metaclass(abc.ABCMeta)
|
||||||
class MatchMakerBase(object):
|
class MatchMakerBase(object):
|
||||||
|
|
||||||
|
|
|
@ -12,15 +12,12 @@
|
||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
import threading
|
import threading
|
||||||
|
|
||||||
import eventlet
|
import eventlet
|
||||||
|
|
||||||
from oslo_messaging._drivers.zmq_driver import zmq_poller
|
from oslo_messaging._drivers.zmq_driver import zmq_poller
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class GreenPoller(zmq_poller.ZmqPoller):
|
class GreenPoller(zmq_poller.ZmqPoller):
|
||||||
|
|
||||||
|
|
|
@ -12,12 +12,9 @@
|
||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
|
|
||||||
from oslo_messaging._i18n import _
|
from oslo_messaging._i18n import _
|
||||||
from oslo_utils import importutils
|
from oslo_utils import importutils
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
# Map zmq_concurrency config option names to the actual module name.
|
# Map zmq_concurrency config option names to the actual module name.
|
||||||
ZMQ_MODULES = {
|
ZMQ_MODULES = {
|
||||||
|
|
|
@ -13,16 +13,12 @@
|
||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
|
|
||||||
from eventlet.green import threading as greenthreading
|
from eventlet.green import threading as greenthreading
|
||||||
import futurist
|
import futurist
|
||||||
|
|
||||||
from oslo_messaging._executors import impl_pooledexecutor
|
from oslo_messaging._executors import impl_pooledexecutor
|
||||||
from oslo_utils import eventletutils
|
from oslo_utils import eventletutils
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class EventletExecutor(impl_pooledexecutor.PooledExecutor):
|
class EventletExecutor(impl_pooledexecutor.PooledExecutor):
|
||||||
"""A message executor which integrates with eventlet.
|
"""A message executor which integrates with eventlet.
|
||||||
|
|
|
@ -13,11 +13,8 @@
|
||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
import threading
|
import threading
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
def version_is_compatible(imp_version, version):
|
def version_is_compatible(imp_version, version):
|
||||||
"""Determine whether versions are compatible.
|
"""Determine whether versions are compatible.
|
||||||
|
|
|
@ -12,8 +12,6 @@
|
||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
|
|
||||||
import fixtures
|
import fixtures
|
||||||
import testtools
|
import testtools
|
||||||
|
|
||||||
|
@ -24,7 +22,6 @@ from oslo_messaging._drivers.zmq_driver import zmq_socket
|
||||||
from oslo_messaging.tests import utils as test_utils
|
from oslo_messaging.tests import utils as test_utils
|
||||||
from oslo_messaging.tests.drivers.zmq import zmq_common
|
from oslo_messaging.tests.drivers.zmq import zmq_common
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
zmq = zmq_async.import_zmq()
|
zmq = zmq_async.import_zmq()
|
||||||
|
|
||||||
|
|
|
@ -12,7 +12,6 @@
|
||||||
# License for the specific language governing permissions and limitations
|
# License for the specific language governing permissions and limitations
|
||||||
# under the License.
|
# under the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
import pickle
|
import pickle
|
||||||
import time
|
import time
|
||||||
|
|
||||||
|
@ -31,7 +30,6 @@ from oslo_messaging._drivers.zmq_driver.client.publishers \
|
||||||
from oslo_messaging.tests import utils as test_utils
|
from oslo_messaging.tests import utils as test_utils
|
||||||
from oslo_messaging.tests.drivers.zmq import zmq_common
|
from oslo_messaging.tests.drivers.zmq import zmq_common
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
zmq = zmq_async.import_zmq()
|
zmq = zmq_async.import_zmq()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue