def send_task_success()

in lambda/python/rs_integration_function/step_function/api.py [0:0]

• 12 lines of code
• 3 McCabe index (conditional complexity)

    def send_task_success(cls, task_token: str, finished_event_details: dict):
        logger.debug({l_task_token: task_token, l_item: finished_event_details})
        try:
            cls.client.send_task_success(
                taskToken=task_token,
                output=json.dumps(finished_event_details)
            )
        except cls.client.exceptions.TaskTimedOut as tto:
            # TaskTimedOut means task has already timed out or has been completed previously.
            logger.warn({
                l_record: finished_event_details,
                l_task_timed_out: tto
            })