您不能动态创建依赖于上游任务输出的任务。您正在混淆计划和执行时间。DAG 定义 和 任务 在计划时间创建。在执行时将创建DAG 运行 和
任务实例 。只有任务 实例 可以产生输出。
Airflow计划程序将
text_file.txt在 计划时间 使用包含的内容来构建动态图。然后将这些任务运送给工人。
工作人员最终将执行
t1任务实例并创建一个新实例
text_file.txt，但此时，
t2任务列表已由调度程序计算并发送给工作人员。
因此，调度程序下次决定运行DAG的时间时，将使用最新
t1任务实例转储到的任何内容
text_file.txt。
如果您的任务很快速并且您的工作人员没有积压，那么这将是上次DAG运行的内容。如果它们积压，
text_file.txt内容可能会过时，并且如果您真的不走运，调度程序会在写入任务实例的同时读取文件，并且您会从中获取不完整的数据
read_text()。
