def send_task_failure()

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

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

    def send_task_failure(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_failure(
                taskToken=task_token,
                error=FinishedEvent.QUERY_FAILED,
                cause=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
            })