PEBCAK

ISISComputingGroup · Dec 6, 2024 · c2faea3 · c2faea3
1 parent 6bfd9d7
commit c2faea3
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 33 deletions.
diff --git a/BlockServerToKafka/block_server_monitor.py b/BlockServerToKafka/block_server_monitor.py
@@ -18,9 +18,10 @@
 from typing import Any
 
 import ca
+from CaChannel import CaChannel, CaChannelException
+
 from BlockServer.core.macros import BLOCK_PREFIX
 from BlockServerToKafka.kafka_producer import ProducerWrapper
-from CaChannel import CaChannel, CaChannelException
 from server_common.utilities import dehex_and_decompress, print_and_log
 
 

diff --git a/BlockServerToKafka/kafka_producer.py b/BlockServerToKafka/kafka_producer.py
@@ -16,13 +16,14 @@
 from time import sleep
 from typing import List
 
-from BlockServerToKafka.forwarder_config import ForwarderConfig
 from kafka import KafkaConsumer, KafkaProducer, errors
-from server_common.utilities import print_and_log
 from streaming_data_types.fbschemas.forwarder_config_update_fc00.Protocol import (
     Protocol,
 )
 
+from BlockServerToKafka.forwarder_config import ForwarderConfig
+from server_common.utilities import print_and_log
+
 
 class ProducerWrapper:
     """

diff --git a/BlockServerToKafka/test_modules/__init__.py b/BlockServerToKafka/test_modules/__init__.py
diff --git a/BlockServerToKafka/test_modules/test_block_server_monitor.py b/BlockServerToKafka/test_modules/test_block_server_monitor.py
@@ -16,9 +16,10 @@
 
 import unittest
 
-from BlockServerToKafka.block_server_monitor import BlockServerMonitor
 from mock import MagicMock, patch
 
+from BlockServerToKafka.block_server_monitor import BlockServerMonitor
+
 
 class TestBlockServerMonitor(unittest.TestCase):
     test_address = "TEST_ADDRESS"

diff --git a/BlockServerToKafka/test_modules/test_forwarder_config.py b/BlockServerToKafka/test_modules/test_forwarder_config.py
@@ -15,7 +15,6 @@
 # http://opensource.org/licenses/eclipse-1.0.php
 import unittest
 
-from BlockServerToKafka.forwarder_config import ForwarderConfig
 from streaming_data_types.fbschemas.forwarder_config_update_fc00.Protocol import (
     Protocol,
 )
@@ -24,6 +23,8 @@
 )
 from streaming_data_types.forwarder_config_update_fc00 import deserialise_fc00
 
+from BlockServerToKafka.forwarder_config import ForwarderConfig
+
 
 class TestForwarderConfig(unittest.TestCase):
     test_schema = "schema"