nik/newdwh2021
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 並行処理→並列処理

Browse Source
This commit is contained in:
shimoda.m@nds-tyo.co.jp 2023-04-19 18:30:06 +09:00
parent 44bef7d91b
commit ecf193e61f
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
ecs/jskult-batch-daily/src/batch/parallel_processes.py
View File

@ -1,4 +1,4 @@
"""並行処理"""
"""並列処理"""
import concurrent.futures
@ -8,7 +8,7 @@ from src.error.exceptions import BatchOperationException
def exec():
# 並行処理を開始
# 並列処理を開始
with concurrent.futures.ThreadPoolExecutor(max_workers=2) as executor:
# 実績更新
@ -27,6 +27,6 @@ def exec():
if sales_laundering_exc is not None or create_bio_sales_lot_exc is not None:
sales_laundering_exc_message = str(sales_laundering_exc) if sales_laundering_exc is not None else ''
create_bio_sales_lot_exc_message = str(create_bio_sales_lot_exc) if create_bio_sales_lot_exc is not None else ''
raise BatchOperationException(f'並行処理中にエラーが発生しました。実績更新="{sales_laundering_exc_message}", 生物由来ロット分解={create_bio_sales_lot_exc_message}')
raise BatchOperationException(f'並列処理中にエラーが発生しました。実績更新="{sales_laundering_exc_message}", 生物由来ロット分解={create_bio_sales_lot_exc_message}')
return

8
ecs/jskult-batch-daily/src/jobctrl_daily.py
View File

@ -98,12 +98,12 @@ def exec():
return constants.BATCH_EXIT_CODE_SUCCESS
try:
# 実績生物由来ロット分解と並行処理
logger.info('並行処理(実績更新-生物由来ロット分解)：起動')
# 実績生物由来ロット分解と並列処理
logger.info('並列処理(実績更新-生物由来ロット分解)：起動')
parallel_processes.exec()
logger.info('並行処理(実績更新-生物由来ロット分解)：終了')
logger.info('並列処理(実績更新-生物由来ロット分解)：終了')
except BatchOperationException as e:
logger.exception(f'並行処理(実績更新-生物由来ロット分解)エラー（異常終了）{e}')
logger.exception(f'並列処理(実績更新-生物由来ロット分解)エラー（異常終了）{e}')
return constants.BATCH_EXIT_CODE_SUCCESS
try: