diff --git a/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py b/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py
index 832cc20c..b4b6e4e7 100644
--- a/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py
+++ b/ecs/jskult-batch-daily/src/batch/dcf_inst_merge/integrate_dcf_inst_merge.py
@@ -40,7 +40,7 @@ def _set_enabled_dct_inst_merge(db: Database) -> list[dict]:
     if _update_dcf_inst_merge(db, 0) > 0:
         # DCF施設統合マスタの過去分の洗い替え
         for row in enabled_dst_inst_merge_records:
-            _update_dcf_inst_cd_new(db, row['dup_opp_cd'], row['dcf_inst_cd'], 0)
+            _update_dcf_inst_cd_new(db, row['dup_opp_cd'], row['dcf_inst_cd'], '')
 
     return enabled_dst_inst_merge_records
 
@@ -52,7 +52,7 @@ def _set_disabled_dct_inst_merge(db: Database):
     if _update_dcf_inst_merge(db, 1) > 0:
         # DCF施設統合マスタの過去分の洗い替え
         for row in disabled_dst_inst_merge_records:
-            _update_dcf_inst_cd_new(db, row['dcf_inst_cd'], row['dup_opp_cd'], 1)
+            _update_dcf_inst_cd_new(db, row['dcf_inst_cd'], row['dup_opp_cd'], '戻し')
 
 
 def _add_ult_ident_presc(db: Database, enabled_dst_inst_merge_records: list[dict]):
@@ -362,10 +362,9 @@ def _update_dcf_inst_merge(db: Database, muko_flg: int) -> int:
     return res.rowcount
 
 
-def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_cd_new_before: str, muko_flg: int):
+def _update_dcf_inst_cd_new(db: Database, dcf_inst_cd_new_after: str, dcf_inst_cd_new_before: str, log_message: str):
     # dcf_inst_mergeをUPDATE
     try:
-        log_message = '' if muko_flg == 0 else '戻し'
         elapsed_time = ElapsedTime()
         sql = """
             UPDATE