diff --git a/ecs/jskult-batch-daily/src/batch/bio_sales/create_bio_sale_lot.py b/ecs/jskult-batch-daily/src/batch/bio_sales/create_bio_sales_lot.py similarity index 83% rename from ecs/jskult-batch-daily/src/batch/bio_sales/create_bio_sale_lot.py rename to ecs/jskult-batch-daily/src/batch/bio_sales/create_bio_sales_lot.py index 49bd19f1..306ff772 100644 --- a/ecs/jskult-batch-daily/src/batch/bio_sales/create_bio_sale_lot.py +++ b/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('生物由来卸販売ロット分解:終了') diff --git a/ecs/jskult-batch-daily/src/batch/parallel_processes.py b/ecs/jskult-batch-daily/src/batch/parallel_processes.py index 1b7db6c7..603b5e52 100644 --- a/ecs/jskult-batch-daily/src/batch/parallel_processes.py +++ b/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])