Skip to content

Commit 21b297b

Browse files
committed
DS-2171: transport.sql: fix broken report_task_progress function.
Signed-off-by: mchrza <maximilian.chrzan@here.com>
1 parent 625757b commit 21b297b

1 file changed

Lines changed: 13 additions & 10 deletions

File tree

xyz-jobs/xyz-job-steps/src/main/resources/jobs/transport.sql

Lines changed: 13 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -801,17 +801,20 @@ RETURNS VOID
801801
LANGUAGE 'plpgsql'
802802
VOLATILE
803803
AS $BODY$
804+
DECLARE
805+
lamda_response RECORD;
804806
BEGIN
805-
PERFORM report_progress(
806-
lambda_function_arn,
807-
lambda_region,
808-
step_payload,
809-
json_build_object(
810-
'type','SpaceBasedTaskUpdate',
811-
'taskId', task_id,
812-
'taskOutput', task_output
813-
)
814-
);
807+
--TODO: Add error handling
808+
SELECT aws_lambda.invoke(aws_commons.create_lambda_function_arn(lambda_function_arn, lambda_region),
809+
json_build_object(
810+
'type','UPDATE_CALLBACK',
811+
'step', step_payload,
812+
'processUpdate', json_build_object(
813+
'type','SpaceBasedTaskUpdate',
814+
'taskId', task_id,
815+
'taskOutput', task_output
816+
)
817+
), 'Event') INTO lamda_response;
815818
END
816819
$BODY$;
817820

0 commit comments

Comments
 (0)