diff --git a/cosmos/converter.py b/cosmos/converter.py index 1b267b0a3..7b3a7cd60 100644 --- a/cosmos/converter.py +++ b/cosmos/converter.py @@ -161,7 +161,7 @@ def __init__( validate_arguments(select, exclude, profile_args, task_args) build_airflow_graph( - nodes=dbt_graph.nodes, + nodes=dbt_graph.filtered_nodes, dag=dag or (task_group and task_group.dag), task_group=task_group, execution_mode=execution_mode,