fix.

mahdigheidi · Feb 15, 2024 · 5b80a5c · 5b80a5c
1 parent 0cb9c7a
commit 5b80a5c
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/kafka_server/broker/file/read.py b/kafka_server/broker/file/read.py
@@ -11,7 +11,6 @@
 from file.segment import Segment
 from manager.env import get_partition_count
 
-
 BROKER_PROJECT_PATH = os.getenv("BROKER_PROJECT_PATH", "/app/")
 sys.path.append(os.path.abspath(BROKER_PROJECT_PATH))
 
@@ -116,8 +115,7 @@ def ack_message(self):
 
     def check_data_exist(self):
         if self.segment.get_read_index() >= self.segment.get_write_index():
-            print(f"No key found {self.segment.get_read_index()} "
-                  f"in {self.segment.get_write_index()}")
+            print(f"No key found {self.segment.get_read_index()} in {self.segment.get_write_index()}")
             return False
 
         key, _ = self.segment.read()