Actualmente estoy usando boto3 (el SDK de Amazon Web Services (AWS) para Python) para crear máquinas de estado, iniciar ejecuciones y también en mis trabajadores para recuperar tareas e informar su estado (completado con éxito o fallido).
Tengo otro servicio que necesita saber el estado de las tareas y me gustaría hacerlo recuperándolo de AWS. Busqué los métodos disponibles y solo es posible obtener el estado de una máquina de estado/ejecución como un todo (EN EJECUCIÓN | CON ÉXITO | FALLIDO | TIEMPO_EXCLUIDO | ABORTADO).
También existe el método get_execution_history, pero cada paso se identifica mediante una identificación numerada secuencialmente y no hay información sobre la tarea en sí (solo en el evento "stateEnteredEventDetails", donde el nombre de la tarea está presente, pero los eventos posteriores pueden no ser relacionados con ella, por lo que es imposible saber si la tarea fue exitosa o no).
¿Realmente no es posible recuperar el estado de una tarea específica o me estoy perdiendo algo?
¡Gracias!
Tuve el mismo problema y parece que las funciones de paso no consideran los estados y las tareas como entidades y, por lo tanto, no hay una API para obtener información sobre ellos.
Para obtener información sobre el estado de la tarea, debe analizar la información en el historial de ejecución. En mi caso primero compruebo el estado de ejecución:
import boto3 import json client = boto3.client("stepfunctions") response = client.describe_execution( executionArn=EXECUTION_ARN ) status = response["status"]y si es "FALLIDO", entonces analizo el historial y obtengo los campos más relevantes para mi caso de uso (para eventos de tipo "TaskFailed"):
response = client.get_execution_history( executionArn=EXECUTION_ARN, maxResults=1000 ) events = response["events"] while response.get("nextToken"): response = client.get_execution_history( executionArn=EXECUTION_ARN, maxResults=1000, nextToken=response["nextToken"] ) events += response["events"] causes = [ json.loads(e["taskFailedEventDetails"]["cause"]) for e in events if e["type"] == "TaskFailed" ] return [ { "ClusterArn": cause["ClusterArn"], "Containers": [ { "ContainerArn": container["ContainerArn"], "Name": container["Name"], "ExitCode": container["ExitCode"], "Overrides": cause["Overrides"]["ContainerOverrides"][i] } for i, container in enumerate(cause["Containers"]) ], "TaskArn": cause["TaskArn"], "StoppedReason": cause["StoppedReason"] } for cause in causes ]