Scrivere un TaskFlow Dag minimale

Il tuo team sta avviando un nuovo progetto di data pipeline. Prima di costruire l'intera pipeline, la tua lead ti chiede di impostare un Dag minimale per verificare che l'ambiente funzioni.

Un file dell'esercizio include dag.test() in fondo, che esegue l'intero Dag in un singolo processo così puoi vedere direttamente l'output dei task.