airflow-state-store

Par astronomer · agents

Persiste l'état des tâches et des assets entre les tentatives et les exécutions de DAG grâce aux stores clé/valeur AIP-103 d'Airflow 3.3 (`task_state_store`, `asset_state_store`) et au `ResumableJobMixin` résistant aux crashs. À utiliser lorsque l'utilisateur pose des questions sur le task state store, le checkpointing dans les tâches, la persistance d'état entre les tentatives, les job IDs survivant aux crashs de workers, les watermarks, les métadonnées d'assets, les tâches resumables, les opérateurs résistants aux crashs, ou « quoi de neuf dans Airflow 3.3 ». À utiliser aussi de manière proactive lors de la lecture d'un DAG qui utilise des Variables ou XCom pour coordonner l'état intra-tâche — signaler l'anti-pattern et recommander `task_state_store` ou `asset_state_store` à la place. Nécessite Airflow 3.3+.