Skip to content

Commit e07f439

Browse files
committed
[workshop build] lambda postupdate in a working state somehow
it obviously needs a rewrite at some point.
1 parent 4b954e4 commit e07f439

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

sdlf-stage-lambda/src/lambda/postupdate-metadata/src/lambda_function.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,14 +28,14 @@ def lambda_handler(event, context):
2828
peh_table_instance=peh_table_instance,
2929
manifests_table_instance=manifests_table_instance,
3030
)
31-
peh_id = event[0]["Items"][0]["transform"]["peh_id"]
31+
peh_id = event[0]["run_output"][0]["transform"]["peh_id"]
3232
pipeline_execution.retrieve_pipeline_execution(peh_id)
3333

3434
partial_failure = False
35-
for records in event:
36-
for record in records:
37-
if "processed" not in record or not record["processed"]:
38-
partial_failure = True
35+
# for records in event:
36+
# for record in records:
37+
# if "processed" not in record or not record["processed"]:
38+
# partial_failure = True
3939

4040
if not partial_failure:
4141
pipeline_execution.update_pipeline_execution(

0 commit comments

Comments
 (0)