From 137bdef64f8341ea7bb85d72127f36a6eaa3f2c1 Mon Sep 17 00:00:00 2001 From: ranchodeluxe Date: Mon, 3 Apr 2023 13:31:57 -0700 Subject: [PATCH] change target to 'staging' --- .../s3_event_bridge_to_sfn_execute/lambda_function.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/terraform/veda-wfs3/functions/s3_event_bridge_to_sfn_execute/lambda_function.py b/terraform/veda-wfs3/functions/s3_event_bridge_to_sfn_execute/lambda_function.py index aefef1b..7a5c6ad 100644 --- a/terraform/veda-wfs3/functions/s3_event_bridge_to_sfn_execute/lambda_function.py +++ b/terraform/veda-wfs3/functions/s3_event_bridge_to_sfn_execute/lambda_function.py @@ -4,11 +4,12 @@ import base64 import ast import json -mwaa_env_name = 'veda-pipeline-sit-mwaa' +mwaa_env_name = 'veda-pipeline-staging-mwaa' dag_name = 'veda_discover' mwaa_cli_command = 'dags trigger' client = boto3.client('mwaa') + def lambda_handler(event, context): for record in event['Records']: print(f"[ RECORD ]: {record}") @@ -46,7 +47,7 @@ def lambda_handler(event, context): mydata = ast.literal_eval(dict_str) print(f"[ DATA ]: {mydata}") print(f"[ STDOUT ]: {base64.b64decode(mydata['stdout'])}") - return { - 'statusCode': 200, - 'body': json.dumps('Hello from Lambda!') - } \ No newline at end of file + return { + 'statusCode': 200, + 'body': json.dumps('Hello from Lambda!') + } \ No newline at end of file