def send_pipeline_execution_success()

in repos/serving/lambdas/functions/processing-job-status-check/lambda_function.py [0:0]

• 18 lines of code
• 1 McCabe index (conditional complexity)

def send_pipeline_execution_success(token):
    try:
        sagemaker.send_pipeline_execution_step_success(
            CallbackToken=token,
            OutputParameters=[
                {
                    "Name": "final_status",
                    "Value": "Glue Job finished.",
                }
            ],
        )
    except:
        logger.info(
            (
                "An error occurred: Step GluePrepCallbackStep is already"
                " in a terminal status, but Step function shouldbe"
            )
        )