🎨 Run isort on the pre processing code

components/pre-processing/pre_processing/constant.py

@@ -1,4 +1,5 @@
 import numpy as np
+
 from pre_processing.utils.loader import get_data_path
 
 DATA_PATH = get_data_path()

components/pre-processing/pre_processing/data_agregation/helpers.py

@@ -1,4 +1,5 @@
 import pandas as pd
+
 from pre_processing.constant import CSV_COLUMNS, DATA_PATH
 from pre_processing.data_completion.helpers import (
     add_ticker,

components/pre-processing/pre_processing/data_agregation/reader.py

@@ -4,6 +4,7 @@
 from typing import IO, Iterator, List, Tuple
 
 import pandas as pd
+
 from pre_processing.constant import DATA_PATH, TARGET_DATE_REGEX
 from pre_processing.data_agregation.find_date import extract_full_day_from_file
 from pre_processing.data_agregation.helpers import generate_dataframe

components/pre-processing/pre_processing/data_completion/generation.py

@@ -2,6 +2,7 @@
 
 import numpy as np
 import pandas as pd
+
 from pre_processing.data_completion.helpers import fast_round, generate_segments
 from pre_processing.decorators import performance_timer_decorator
 

components/pre-processing/pre_processing/dataframe_extraction/day.py

@@ -1,6 +1,7 @@
 import datetime
 
 import pandas as pd
+
 from pre_processing.data_completion.generation import complete_data
 
 

components/pre-processing/pre_processing/dataframe_extraction/hour.py

@@ -1,6 +1,7 @@
 from typing import Generator
 
 import pandas as pd
+
 from pre_processing.data_completion.generation import complete_data
 
 

components/pre-processing/pre_processing/dataframe_extraction/month.py

@@ -1,4 +1,5 @@
 import pandas as pd
+
 from pre_processing.data_completion.generation import complete_data
 from pre_processing.dataframe_extraction import day
 

components/pre-processing/pre_processing/dataframe_extraction/year.py

@@ -1,4 +1,5 @@
 import pandas as pd
+
 from pre_processing.data_completion.generation import complete_data
 from pre_processing.dataframe_extraction import day
 

components/pre-processing/pre_processing/kafka/admin.py

@@ -2,6 +2,7 @@
 
 from confluent_kafka.admin import AdminClient as _AdminClient
 from confluent_kafka.admin import NewTopic
+
 from pre_processing.constant import MARKET_DATA_PARTIONS
 
 logger = logging.getLogger("pre_processing.kafka.admin")

components/pre-processing/pre_processing/kafka/avro.py

@@ -1,6 +1,7 @@
 import logging
 
 from confluent_kafka.schema_registry import Schema, SchemaRegistryClient
+
 from pre_processing.utils.loader import get_avro_schema, get_kafka_config
 
 logger = logging.getLogger("pre_processing.kafka.avro")

components/pre-processing/pre_processing/kafka/data_pipeline.py

@@ -8,6 +8,7 @@
 from typing import Dict, Generator, List, cast
 
 import pandas as pd
+
 from pre_processing.constant import MARKET_DATA_PARTIONS
 from pre_processing.dataframe_extraction.hour import complete_a_day_hour_by_hour
 from pre_processing.decorators import performance_timer_decorator

components/pre-processing/pre_processing/kafka/producer.py

@@ -3,6 +3,7 @@
 
 from confluent_kafka import SerializingProducer
 from confluent_kafka.schema_registry.avro import AvroSerializer
+
 from pre_processing.kafka.avro import AvroService
 
 logger = logging.getLogger("pre_processing.kafka.producer")

components/pre-processing/pre_processing/main.py

@@ -8,6 +8,7 @@
 
 import pandas as pd
 from confluent_kafka.schema_registry.error import SchemaRegistryError
+
 from pre_processing.constant import DATA_PATH, StockChartType
 from pre_processing.data_agregation.helpers import save_date_data
 from pre_processing.data_agregation.reader import gather_data

components/pre-processing/pyproject.toml

@@ -10,7 +10,7 @@ packages = [{ include = "pre_processing" }]
 pre-processing = "pre_processing.main:main"
 
 [tool.poetry.dependencies]
-python = ">=3.11"
+python = ">=3.10"
 matplotlib = "^3.8.0"
 pandas = "^2.1.1"
 numpy = "^1.26.1"