#72725·airflow

任务状态存储通过位置映射索引进行键值映射,并且在清除时仍然存在,因此重新展开的列表会默默继承错误项的状态

作者: vasilisnasopoulos创建于 2026年9月8日更新于 2026年9月25日

--- ATTEMPT 1 (items=[a,b,c]) --- OBSERVE map_index=0 item='a' checkpoint_read=None -> wrote 'a' OBSERVE map_index=1 item='b' checkpoint_read=None -> wrote 'b' OBSERVE map_index=2 item='c' checkpoint_read=None -> wrote 'c'

--- ATTEMPT 2 (clear-and-rerun in place, items=[z,a,b,c]) --- OBSERVE map_index=0 item='z' checkpoint_read='a' [MISPAIRED] OBSERVE map_index=1 item='a' checkpoint_read='b' [MISPAIRED] OBSERVE map_index=2 item='b' checkpoint_read='c' [MISPAIRED] OBSERVE map_index=3 item='c' checkpoint_read=None -> wrote 'c' [rerun] final dagrun state: success