diff options
Diffstat (limited to 'kombu/transport/sqlalchemy')
-rw-r--r-- | kombu/transport/sqlalchemy/__init__.py | 3 | ||||
-rw-r--r-- | kombu/transport/sqlalchemy/models.py | 7 |
2 files changed, 4 insertions, 6 deletions
diff --git a/kombu/transport/sqlalchemy/__init__.py b/kombu/transport/sqlalchemy/__init__.py index 08af3054..863659c9 100644 --- a/kombu/transport/sqlalchemy/__init__.py +++ b/kombu/transport/sqlalchemy/__init__.py @@ -2,7 +2,6 @@ # SQLAlchemy overrides != False to have special meaning and pep8 complains # flake8: noqa -from __future__ import absolute_import, unicode_literals import threading from json import loads, dumps @@ -33,7 +32,7 @@ class Channel(virtual.Channel): def __init__(self, connection, **kwargs): self._configure_entity_tablenames(connection.client.transport_options) - super(Channel, self).__init__(connection, **kwargs) + super().__init__(connection, **kwargs) def _configure_entity_tablenames(self, opts): self.queue_tablename = opts.get('queue_tablename', 'kombu_queue') diff --git a/kombu/transport/sqlalchemy/models.py b/kombu/transport/sqlalchemy/models.py index 78d2645a..eefa529b 100644 --- a/kombu/transport/sqlalchemy/models.py +++ b/kombu/transport/sqlalchemy/models.py @@ -1,5 +1,4 @@ """Kombu transport using SQLAlchemy as the message store.""" -from __future__ import absolute_import, unicode_literals import datetime @@ -14,7 +13,7 @@ metadata = MetaData() ModelBase = declarative_base(metadata=metadata, class_registry=class_registry) -class Queue(object): +class Queue: """The queue class.""" __table_args__ = {'sqlite_autoincrement': True, 'mysql_engine': 'InnoDB'} @@ -27,14 +26,14 @@ class Queue(object): self.name = name def __str__(self): - return '<Queue({self.name})>'.format(self=self) + return f'<Queue({self.name})>' @declared_attr def messages(cls): return relation('Message', backref='queue', lazy='noload') -class Message(object): +class Message: """The message class.""" __table_args__ = ( |