Zachary Bluhm
10/14/2022, 2:21 PMowen
10/14/2022, 7:09 PMdbt run
command, so control over concurrency and order of execution is handled entirely within dbt. So for cases like this, your best bet might be a feature on dbt's end which enabled that sort of concurrency limiting.Zachary Bluhm
10/14/2022, 7:13 PMdbt run
will be invoked for each model .In this case would it be possible? Not sure if you can tag ops or not, let me checkowen
10/14/2022, 7:27 PMdagster/priority
tag (https://docs.dagster.io/_apidocs/execution#dagster.multi_or_in_process_executor), but that's the extent to which an op tag can impact execution behavior at the momentZachary Bluhm
10/14/2022, 7:37 PMowen
10/14/2022, 8:16 PMsandy
10/14/2022, 9:34 PMAlso - Is there a way to prevent backfills from continuing if a prior job has a failed op?how we'd like to ultimately support this: https://github.com/dagster-io/dagster/issues/9896 I'm hoping we can get to that before the end of the year in the mean time, I think your best bet would be to include logic inside your op to fast-fail if the prior run / materialization isn't there. we can show you what that would look like if it would be helpful
Zachary Bluhm
10/24/2022, 3:52 PMin the mean time, I think your best bet would be to include logic inside your op to fast-fail if the prior run / materialization isn't there. we can show you what that would look like if it would be helpful
Would like to play around with this a bit more as part of our pilot