步骤功能：批处理总是在异常抛出时返回 State.TaskFailed 错误

如何解决步骤功能：批处理总是在异常抛出时返回 State.TaskFailed 错误

我有以下批处理配置：

python 脚本（图像）和作业定义通过 gitlab 部署到 AWS ECR 并用作 step 函数中的任务。整个脚本被 try except 包含自定义错误类的块包围。

错误类别的例子

class CustomException(Exception):

       def __init__(self,message):

             self.message = message

主函数示例

try: 

... 

except Exception as ex

raise CustomException(f"An exception occurred. Exception {str(ex)}")

此任务的步骤函数定义为：

"Batch": {

    "Type": "Task","Resource": "arn:aws:states:::batch:submitJob.sync","Parameters": {

    "JobDeFinition": "...","JobName": ".....","JobQueue": ".....","Parameters": {

        "parameters.$": "States.JsonToString($)"

    },"ContainerOverrides": {

        "Command": [

            "Ref::parameters"

        ]

    }

},"Retry": [

{

    "ErrorEquals": [

        "CustomException"

    ],"IntervalSeconds": 60,"MaxAttempts": 3

}

],"Catch": [

{

    "ErrorEquals": [

        "CustomException"

    ],"ResultPath": "$.errorMessage","Next": "Failed or Success?"

},{

    "ErrorEquals": [

        "States.ALL"

    ],"Next": "Failed or Success?"

 }

],"ResultPath": null,"Next": "...."

}

错误处理的主要原因当然是发送到自定义位置的适当消息，以及自定义异常的重试策略。

这个问题是，无论我如何尝试引发异常，步骤函数标记为：

"errorMessage": {

"Error": "States.TaskFailed","Cause": "{\"Attempts\":[{\"Container\":{\"ContainerInstanceArn\":\".....\",\"ExitCode\":1,\"LogStreamName ........}

为什么使用以下错误覆盖异常。这种行为是预期的还是有办法处理的？

如何克服这个 States.TaskFailed