From 85647c25630be929af6eea58fa646fb7ebb47196 Mon Sep 17 00:00:00 2001 From: "mori.k" Date: Wed, 21 May 2025 18:14:57 +0900 Subject: [PATCH] =?UTF-8?q?=E3=83=90=E3=83=83=E3=83=81=E5=AE=9F=E8=A1=8C?= =?UTF-8?q?=E7=AE=A1=E7=90=86=E3=83=86=E3=83=BC=E3=83=96=E3=83=AB(DynamoDB?= =?UTF-8?q?)=E6=93=8D=E4=BD=9C=E3=82=AF=E3=83=A9=E3=82=B9=E3=81=AE?= =?UTF-8?q?=E5=AE=9F=E8=A3=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/manager/jskult_batch_run_manager.py | 28 +++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 ecs/jskult-batch/src/manager/jskult_batch_run_manager.py diff --git a/ecs/jskult-batch/src/manager/jskult_batch_run_manager.py b/ecs/jskult-batch/src/manager/jskult_batch_run_manager.py new file mode 100644 index 00000000..3a55f7b9 --- /dev/null +++ b/ecs/jskult-batch/src/manager/jskult_batch_run_manager.py @@ -0,0 +1,28 @@ +class JskultBatchRunManager: + def __init__(self, execution_id: str): + self._execution_id: str = execution_id + + def batch_success(self): + try: + self._put_dynamodb_record('success') + except Exception as e: + raise e + + def batch_failed(self): + try: + self._put_dynamodb_record('failed') + except Exception as e: + raise e + + def batch_retry(self): + try: + self._put_dynamodb_record('retry') + except Exception as e: + raise e + + def _put_dynamodb_record(self, execution_id: str): + try: + self._execution_id = execution_id + # TODO バッチ実行管理テーブルの登録、更新（upsert) + except Exception as e: + raise e \ No newline at end of file