Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Application plan in airflow is broken #2780

Open
serkef opened this issue Jun 17, 2024 · 3 comments
Open

Application plan in airflow is broken #2780

serkef opened this issue Jun 17, 2024 · 3 comments
Labels
Bug Something isn't working Scheduler: Airflow

Comments

@serkef
Copy link
Contributor

serkef commented Jun 17, 2024

When I apply some changes in multiple models, the application plan is broken. Some expected tasks are missing and the tasks are not in the correct order. This affects the correctness of the data.
I haven't managed to create a small reproduction of this, but I've met it multiple times across 0.101 and 0.104 versions.

Here I changed all my models' types to be incremental by partition instead of date (new model kind supporting bq).
The DAG is wrong. Most of the models are missing snapshots and task dependency is wrong.
image
image

@serkef
Copy link
Contributor Author

serkef commented Jun 17, 2024

@izeigerman izeigerman added Bug Something isn't working Scheduler: Airflow labels Jun 20, 2024
@serkef
Copy link
Contributor Author

serkef commented Jun 28, 2024

In the chat @izeigerman mentioned they suspected the sensor. I met the same problem again, tried multiple times planning prod getting the same weird behavior repeatedly. I changed the DAG leaving out the external sensor and it worked.
I still don't know if this is incidental, but it may help track the issue down.
Also, nobody else has this issue apart from me :P so that would be another reason to suspect the sensor.

@serkef
Copy link
Contributor Author

serkef commented Jun 28, 2024

Actually I can confirm it.
While the DAG was running, I changed the dag python file to re-add the sensor and the DAG got messed up (pic 1).
Removing again the sensor fixed the dag (pic 2). That's the exact same DAG in the middle of its run.

image image

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Bug Something isn't working Scheduler: Airflow
Projects
None yet
Development

No branches or pull requests

2 participants