DbtCliEventMessage Unable to Handle Sources about dagster HOT 2 CLOSED

You're probably doing something like:

@dbt_assets(manifest=...)
def my_dbt_assets(context: AssetExecutionContext, dbt: DbtCliResource):
    ...
    yield from dbt.cli(["source", "freshness"], raise_on_error=False).stream()

But we're not supposed to yield any events from dbt source freshness anyways since those are related to dbt sources. We only want to yield events on dbt model materializations and dbt tests.

As a workaround, you could just call .wait() instead. This way, your dbt command is still invoked, but no events are yielded.

@dbt_assets(manifest=...)
def my_dbt_assets(context: AssetExecutionContext, dbt: DbtCliResource):
    ...
    dbt.cli(["source", "freshness"], raise_on_error=False).wait()

In the future, we still want the .stream() to work with dbt source freshness, even though it will do nothing. #20315 will resolve that.

from dagster.

Thanks Rex. I missed that and glad that was merged!

from dagster.