Run dbt models independently for a @dbt_assets using AutomationCondition.eager() and default_automation_condition_sensor #31072
Unanswered
julietteponnet
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
In my current workflow, we are using Dagster and DBT integration as follow:
Dagster assets are set up with an AutomationCondition.eager() policy, which automatically materialises upstream assets whenever any dependency is updated (see official doc) and because my dbt assets have an automation condition in your code location, a sensor with the name default_automation_condition_sensor is created for automatically. Here is how it looks:
As first step, a custom ingestion sensor triggers extraction of our data into a raw asset, and then with the eager automation condition being met, default_automation_condition_sensor is used to materialises downstream asset (dependencies are defined in the dbt manifest). The issue is that AutomationCondition.eager() kicks off a large dbt job that contains many assets in a single run and I am facing two major issues:
Do you have any suggestions to solve those issues? Any workaround maybe? We have more than hundred of models so creating custom sensors with custom conditions per asset is not feasible
Beta Was this translation helpful? Give feedback.
All reactions