From 73e916bb693f5e99d78a391520a2486f8307d363 Mon Sep 17 00:00:00 2001 From: Ryan McGinty Date: Mon, 17 Jun 2024 16:29:09 -0700 Subject: [PATCH] fixes for dist data sync fragment --- .../constructs_/sfn/fragments/informatics/data_sync.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/aibs_informatics_cdk_lib/constructs_/sfn/fragments/informatics/data_sync.py b/src/aibs_informatics_cdk_lib/constructs_/sfn/fragments/informatics/data_sync.py index f727c26..e4c5528 100644 --- a/src/aibs_informatics_cdk_lib/constructs_/sfn/fragments/informatics/data_sync.py +++ b/src/aibs_informatics_cdk_lib/constructs_/sfn/fragments/informatics/data_sync.py @@ -162,7 +162,7 @@ def __init__( self, f"{id}: Batch Data Sync: Map Start", comment="Runs requests for batch sync in parallel", - items_path=f"$.tasks.{prep_batch_sync_task_name}.response.Payload.requests", + items_path=f"$.tasks.{prep_batch_sync_task_name}.response.requests", result_path=sfn.JsonPath.DISCARD, ) @@ -172,7 +172,7 @@ def __init__( id=f"{id}: Batch Data Sync", env_base=env_base, name="batch-data-sync", - payload_path="$.request", + payload_path="$.requests", image=( aibs_informatics_docker_asset if isinstance(aibs_informatics_docker_asset, str)