feat: フォルダ構成、関数名を修正
This commit is contained in:
parent
d00bf2699e
commit
7ce58fac4f
@ -1,9 +1,9 @@
|
||||
"""実消化&アルトマーク 日次バッチのエントリーポイント"""
|
||||
from src.jobctrl_daily import batch_process
|
||||
from src import jobctrl_daily
|
||||
|
||||
if __name__ == '__main__':
|
||||
try:
|
||||
exit(batch_process())
|
||||
exit(jobctrl_daily.exec())
|
||||
except Exception:
|
||||
# エラーが起きても、正常系のコードで返す。
|
||||
# エラーが起きた事実はbatch_process内でログを出す。
|
||||
|
||||
@ -9,7 +9,7 @@ logger = get_logger('48-施設担当者マスタ洗替')
|
||||
batch_config = BatchConfig.get_instance()
|
||||
|
||||
|
||||
def batch_process():
|
||||
def exec():
|
||||
db = Database.get_instance()
|
||||
db.connect()
|
||||
logger.info('##########################')
|
||||
@ -1,11 +1,11 @@
|
||||
from src.batch.datachange import emp_chg_inst_lau
|
||||
from src.batch.laundering import emp_chg_inst_laundering
|
||||
from src.logging.get_logger import get_logger
|
||||
|
||||
logger = get_logger('実績洗替')
|
||||
|
||||
|
||||
def batch_process():
|
||||
def exec():
|
||||
"""実績洗替処理"""
|
||||
logger.info('Start Jisseki Araigae Batch PGM.')
|
||||
# 施設担当者洗替
|
||||
emp_chg_inst_lau.batch_process()
|
||||
emp_chg_inst_laundering.exec()
|
||||
@ -1,8 +1,10 @@
|
||||
from src.batch import jissekiaraigae
|
||||
"""実消化&アルトマーク 日次バッチ処理"""
|
||||
|
||||
from src.batch.batch_functions import (
|
||||
get_batch_statuses, update_batch_process_complete,
|
||||
update_batch_processing_flag_in_processing)
|
||||
from src.batch.common.batch_config import BatchConfig
|
||||
from src.batch.laundering import sales_laundering
|
||||
from src.batch.ultmarc import ultmarc_process
|
||||
from src.error.exceptions import BatchOperationException
|
||||
from src.logging.get_logger import get_logger
|
||||
@ -14,7 +16,7 @@ logger = get_logger('日次処理コントロール')
|
||||
batch_config = BatchConfig.get_instance()
|
||||
|
||||
|
||||
def batch_process():
|
||||
def exec():
|
||||
try:
|
||||
logger.info('日次ジョブ:開始')
|
||||
try:
|
||||
@ -123,7 +125,7 @@ def batch_process():
|
||||
try:
|
||||
# ここで、生物由来ロット分解と並行処理
|
||||
logger.info('実績更新:起動')
|
||||
jissekiaraigae.batch_process()
|
||||
sales_laundering.exec()
|
||||
logger.info('生物由来ロット分解:起動')
|
||||
logger.info('実績更新:終了')
|
||||
logger.info('生物由来ロット分解:終了')
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user