Merge "Trival: Remove unused logging import In some files"
This commit is contained in:
commit
a63a2ef43d
@ -25,15 +25,11 @@ Serves to construct an association between a project + queue -> pool.
|
|||||||
}
|
}
|
||||||
"""
|
"""
|
||||||
|
|
||||||
from oslo_log import log as logging
|
|
||||||
|
|
||||||
from zaqar.storage import base
|
from zaqar.storage import base
|
||||||
from zaqar.storage import errors
|
from zaqar.storage import errors
|
||||||
from zaqar.storage.mongodb import utils
|
from zaqar.storage.mongodb import utils
|
||||||
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
PRIMARY_KEY = utils.PROJ_QUEUE_KEY
|
PRIMARY_KEY = utils.PROJ_QUEUE_KEY
|
||||||
|
|
||||||
CATALOGUE_INDEX = [
|
CATALOGUE_INDEX = [
|
||||||
|
@ -24,7 +24,6 @@ Field Mappings:
|
|||||||
import datetime
|
import datetime
|
||||||
|
|
||||||
from bson import objectid
|
from bson import objectid
|
||||||
from oslo_log import log as logging
|
|
||||||
from oslo_utils import timeutils
|
from oslo_utils import timeutils
|
||||||
|
|
||||||
from zaqar import storage
|
from zaqar import storage
|
||||||
@ -32,9 +31,6 @@ from zaqar.storage import errors
|
|||||||
from zaqar.storage.mongodb import utils
|
from zaqar.storage.mongodb import utils
|
||||||
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class ClaimController(storage.Claim):
|
class ClaimController(storage.Claim):
|
||||||
"""Implements claim resource operations using MongoDB.
|
"""Implements claim resource operations using MongoDB.
|
||||||
|
|
||||||
|
@ -17,7 +17,6 @@
|
|||||||
|
|
||||||
import ssl
|
import ssl
|
||||||
|
|
||||||
from oslo_log import log as logging
|
|
||||||
import pymongo
|
import pymongo
|
||||||
import pymongo.errors
|
import pymongo.errors
|
||||||
|
|
||||||
@ -28,9 +27,6 @@ from zaqar.storage.mongodb import controllers
|
|||||||
from zaqar.storage.mongodb import options
|
from zaqar.storage.mongodb import options
|
||||||
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
def _connection(conf):
|
def _connection(conf):
|
||||||
# NOTE(flaper87): remove possible zaqar specific
|
# NOTE(flaper87): remove possible zaqar specific
|
||||||
# schemes like: mongodb.fifo
|
# schemes like: mongodb.fifo
|
||||||
|
@ -15,7 +15,6 @@
|
|||||||
import functools
|
import functools
|
||||||
|
|
||||||
import msgpack
|
import msgpack
|
||||||
from oslo_log import log as logging
|
|
||||||
from oslo_utils import timeutils
|
from oslo_utils import timeutils
|
||||||
from oslo_utils import uuidutils
|
from oslo_utils import uuidutils
|
||||||
|
|
||||||
@ -26,8 +25,6 @@ from zaqar.storage.redis import messages
|
|||||||
from zaqar.storage.redis import scripting
|
from zaqar.storage.redis import scripting
|
||||||
from zaqar.storage.redis import utils
|
from zaqar.storage.redis import utils
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
QUEUE_CLAIMS_SUFFIX = 'claims'
|
QUEUE_CLAIMS_SUFFIX = 'claims'
|
||||||
CLAIM_MESSAGES_SUFFIX = 'messages'
|
CLAIM_MESSAGES_SUFFIX = 'messages'
|
||||||
|
|
||||||
|
@ -12,7 +12,6 @@
|
|||||||
# See the License for the specific language governing permissions and
|
# See the License for the specific language governing permissions and
|
||||||
# limitations under the License.
|
# limitations under the License.
|
||||||
|
|
||||||
from oslo_log import log as logging
|
|
||||||
import redis
|
import redis
|
||||||
import redis.sentinel
|
import redis.sentinel
|
||||||
from six.moves import urllib
|
from six.moves import urllib
|
||||||
@ -24,7 +23,6 @@ from zaqar import storage
|
|||||||
from zaqar.storage.redis import controllers
|
from zaqar.storage.redis import controllers
|
||||||
from zaqar.storage.redis import options
|
from zaqar.storage.redis import options
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
REDIS_DEFAULT_PORT = 6379
|
REDIS_DEFAULT_PORT = 6379
|
||||||
SENTINEL_DEFAULT_PORT = 26379
|
SENTINEL_DEFAULT_PORT = 26379
|
||||||
DEFAULT_SOCKET_TIMEOUT = 0.1
|
DEFAULT_SOCKET_TIMEOUT = 0.1
|
||||||
|
@ -15,7 +15,6 @@
|
|||||||
import functools
|
import functools
|
||||||
|
|
||||||
import msgpack
|
import msgpack
|
||||||
from oslo_log import log as logging
|
|
||||||
from oslo_utils import timeutils
|
from oslo_utils import timeutils
|
||||||
import redis
|
import redis
|
||||||
|
|
||||||
@ -24,8 +23,6 @@ from zaqar import storage
|
|||||||
from zaqar.storage import errors
|
from zaqar.storage import errors
|
||||||
from zaqar.storage.redis import utils
|
from zaqar.storage.redis import utils
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
QUEUES_SET_STORE_NAME = 'queues_set'
|
QUEUES_SET_STORE_NAME = 'queues_set'
|
||||||
MESSAGE_IDS_SUFFIX = 'messages'
|
MESSAGE_IDS_SUFFIX = 'messages'
|
||||||
|
|
||||||
|
@ -13,8 +13,6 @@
|
|||||||
# License for the specific language governing permissions and limitations under
|
# License for the specific language governing permissions and limitations under
|
||||||
# the License.
|
# the License.
|
||||||
|
|
||||||
import logging
|
|
||||||
|
|
||||||
import sqlalchemy as sa
|
import sqlalchemy as sa
|
||||||
|
|
||||||
from zaqar.common import decorators
|
from zaqar.common import decorators
|
||||||
@ -24,9 +22,6 @@ from zaqar.storage.sqlalchemy import options
|
|||||||
from zaqar.storage.sqlalchemy import tables
|
from zaqar.storage.sqlalchemy import tables
|
||||||
|
|
||||||
|
|
||||||
LOG = logging.getLogger(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
class ControlDriver(storage.ControlDriverBase):
|
class ControlDriver(storage.ControlDriverBase):
|
||||||
|
|
||||||
def __init__(self, conf, cache):
|
def __init__(self, conf, cache):
|
||||||
|
Loading…
Reference in New Issue
Block a user