diff --git a/ecs/jskult-batch/src/batch/dcf_inst_merge_io.py b/ecs/jskult-batch/src/batch/dcf_inst_merge_io.py index 5aad9b7d..1297ae71 100644 --- a/ecs/jskult-batch/src/batch/dcf_inst_merge_io.py +++ b/ecs/jskult-batch/src/batch/dcf_inst_merge_io.py @@ -115,10 +115,10 @@ class DcfInstMergeIO(JskultBatchEntrypoint): # DCF施設削除新規マスタ出力 logger.info('DCF施設削除新規マスタ出力を開始します。') - dcf_inst_merge_all_records = self._select_dcf_inst_merge_all(db) + dcf_inst_merge_records = self._select_dcf_inst_merge(db) file_path = self._make_csv_data( self.environment.DCF_INST_MERGE_SEND_FILE_NAME, - dcf_inst_merge_all_records) + dcf_inst_merge_records) # CSVをS3にアップロード self._upload_dcf_inst_merge_csv_file( @@ -284,7 +284,7 @@ class DcfInstMergeIO(JskultBatchEntrypoint): return - def _select_dcf_inst_merge_all(self, db: Database) -> tuple[bool, list[dict]]: + def _select_dcf_inst_merge(self, db: Database) -> tuple[bool, list[dict]]: try: sql = """\ SELECT @@ -302,8 +302,8 @@ class DcfInstMergeIO(JskultBatchEntrypoint): FROM src07.dcf_inst_merge """ - dcf_inst_merge_all_records = db.execute_select(sql) - return dcf_inst_merge_all_records + dcf_inst_merge_records = db.execute_select(sql) + return dcf_inst_merge_records except Exception as e: raise BatchOperationException(e)