From 24f5dfe17b19f29447b5240348e521649cc3898a Mon Sep 17 00:00:00 2001 From: o-mura Date: Tue, 28 May 2024 17:47:04 +0900 Subject: [PATCH] Update update_attempt.py fixed bug --- .../workflow_monitoring/scripts/update_attempt.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/scenarios/monitoring/workflow_monitoring/scripts/update_attempt.py b/scenarios/monitoring/workflow_monitoring/scripts/update_attempt.py index 463520f9..c2bb396e 100644 --- a/scenarios/monitoring/workflow_monitoring/scripts/update_attempt.py +++ b/scenarios/monitoring/workflow_monitoring/scripts/update_attempt.py @@ -44,10 +44,10 @@ def insert_attempt_info(import_unixtime, endpoint, apikey, dest_db, dest_table, client.load_table_from_dataframe(df, dest_table, if_exists='append', fmt='msgpack') def run(session_unixtime, dest_db, dest_table, ids, api_endpoint='api.treasuredata.com', workflow_endpoint='api-workflow.treasuredata.com'): - id_list = ids.split(',') - if len(id_list) == 0: + if len(ids) == 0: print('no update record') return + id_list = ids.split(',') delete_attempt_info(api_endpoint, os.environ['TD_API_KEY'], dest_db, dest_table, id_list) workflow_url = 'https://%s/api/attempts' % workflow_endpoint + '/%s' @@ -56,4 +56,4 @@ def run(session_unixtime, dest_db, dest_table, ids, api_endpoint='api.treasureda if len(l) == 0: print('no update record') return - insert_attempt_info(session_unixtime, 'https://%s' % api_endpoint, os.environ['TD_API_KEY'], dest_db, dest_table, l) \ No newline at end of file + insert_attempt_info(session_unixtime, 'https://%s' % api_endpoint, os.environ['TD_API_KEY'], dest_db, dest_table, l)