feat: 並行処理を元に戻した(async-await→ThreadPoolExecutor)

ecs/jskult-batch-daily/src/batch/bio_sales/create_bio_sales_lot.py

@@ -13,6 +13,12 @@ def exec():
         logger.info('営業日ではないため、生物由来卸販売ロット分解処理をスキップします。')
         return
 
+    # 非同期処理のサンプル
+    import time
+    for _ in range(50):
+        logger.info('処理中')
+        time.sleep(0.5)
+
     # TODO: ここに処理を追記していく
 
     logger.debug('生物由来卸販売ロット分解：終了')

ecs/jskult-batch-daily/src/batch/parallel_processes.py

@@ -2,7 +2,7 @@
 
 import concurrent.futures
 
-from src.batch.bio_sales import create_bio_sale_lot
+from src.batch.bio_sales import create_bio_sales_lot
 from src.batch.laundering import sales_laundering
 from src.error.exceptions import BatchOperationException
 
@@ -14,7 +14,7 @@ def exec():
         # 実績更新
         future_sales_laundering = executor.submit(sales_laundering.exec)
         # 生物由来ロット分解
-        future_create_bio_sales_lot = executor.submit(create_bio_sale_lot.exec)
+        future_create_bio_sales_lot = executor.submit(create_bio_sales_lot.exec)
 
         # 両方の処理が完了するまで待つ
         concurrent.futures.wait([future_sales_laundering, future_create_bio_sales_lot])