[pre-commit.ci] auto fixes from pre-commit.com hooks

for more information, see https://pre-commit.ci

Author: pre-commit-ci[bot]

kombu/transport/rocketmq.py

@@ -42,7 +42,7 @@
 
 Concept
 =================
-As a plugable transport, it uses RocketMQ to abstract certain AMQP
+As a pluggable transport, it uses RocketMQ to abstract certain AMQP
 semantics with the trade-offs and limitations.
 
 In RocketMQ, the two core concepts most closely related to publishing and consuming
@@ -101,24 +101,26 @@
 """
 
 from __future__ import annotations
+
 import string
 import threading
-from queue import Empty
 from dataclasses import dataclass
+from queue import Empty
 
 from kombu.connection import Connection
 from kombu.exceptions import KombuError
 from kombu.log import get_logger
 from kombu.transport import virtual
 from kombu.utils import scheduling
-from kombu.utils.encoding import str_to_bytes, safe_str
+from kombu.utils.encoding import safe_str, str_to_bytes
 from kombu.utils.functional import retry_over_time
 from kombu.utils.json import dumps, loads
 
 try:
     import rocketmq
-    from rocketmq import (Producer, Message as RocketmqMessage, SimpleConsumer,
-                          ClientConfiguration, Credentials, FilterExpression)
+    from rocketmq import ClientConfiguration, Credentials, FilterExpression
+    from rocketmq import Message as RocketmqMessage
+    from rocketmq import Producer, SimpleConsumer
     from rocketmq.grpc_protocol import FilterType
     from rocketmq.v5.util import Misc
     DEFAULT_FILTER_EXP = FilterExpression.TAG_EXPRESSION_SUB_ALL

t/unit/transport/test_rocketmq.py

@@ -2,26 +2,28 @@
 
 from queue import Empty
 from typing import cast
-from unittest.mock import Mock, patch, MagicMock
+from unittest.mock import MagicMock, Mock, patch
 
 import pytest
+from rocketmq import (ClientConfiguration, FilterExpression, Producer,
+                      SimpleConsumer)
+from rocketmq.grpc_protocol import FilterType
 
 import kombu.transport.virtual
 from kombu import Connection
+from kombu.transport import rocketmq
+from kombu.transport.rocketmq import (ACK_ENDPOINTS_KEY, ACK_HANDLE_KEY,
+                                      ACK_MESSAGE_ID_KEY, ACK_TOPIC_KEY,
+                                      AMQP_QUEUE_KEY, DEFAULT_GROUP_FMT,
+                                      DELIVERY_ATTEMPT_KEY,
+                                      GLOBAL_PRODUCER_KEY, MAX_BATCH_COUNT,
+                                      ConsumerConfig, _ack_rocketmq_message,
+                                      _message_to_rocketmq_ack_message,
+                                      _queue_to_topic)
 from kombu.utils.encoding import str_to_bytes
 from kombu.utils.json import dumps
 from kombu.utils.uuid import uuid
 
-from kombu.transport import rocketmq
-from kombu.transport.rocketmq import _message_to_rocketmq_ack_message, DEFAULT_GROUP_FMT, ConsumerConfig, \
-    GLOBAL_PRODUCER_KEY, MAX_BATCH_COUNT, ACK_ENDPOINTS_KEY, ACK_MESSAGE_ID_KEY, ACK_TOPIC_KEY, ACK_HANDLE_KEY, \
-    DELIVERY_ATTEMPT_KEY, AMQP_QUEUE_KEY, _ack_rocketmq_message, _queue_to_topic
-
-from rocketmq import SimpleConsumer, Producer, ClientConfiguration
-from rocketmq.grpc_protocol import FilterType
-from rocketmq import FilterExpression
-
-
 AK = 'ak'
 SK = 'sk'
 HOST = 'localhost'