Escribir un Dag mínimo con TaskFlow

Tu equipo va a iniciar un nuevo proyecto de canalización de datos. Antes de construir la canalización completa, tu lead te pide configurar un Dag mínimo para comprobar que el entorno funciona.

Un archivo del ejercicio incluye dag.test() al final, que ejecuta todo el Dag en un único proceso para que puedas ver directamente la salida de las tareas.