summaryrefslogtreecommitdiff
path: root/kombu/transport/sqlalchemy
diff options
context:
space:
mode:
Diffstat (limited to 'kombu/transport/sqlalchemy')
-rw-r--r--kombu/transport/sqlalchemy/__init__.py3
-rw-r--r--kombu/transport/sqlalchemy/models.py7
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__ = (