diff --git a/dev/dags/example_cosmos_sources.py b/dev/dags/example_cosmos_sources.py index fd5460c73..25ab2c872 100644 --- a/dev/dags/example_cosmos_sources.py +++ b/dev/dags/example_cosmos_sources.py @@ -66,7 +66,6 @@ def convert_exposure(dag: DAG, task_group: TaskGroup, node: DbtNode, **kwargs): DbtResourceType("source"): convert_source, # known dbt node type to Cosmos (part of DbtResourceType) DbtResourceType("exposure"): convert_exposure, # dbt node type new to Cosmos (will be added to DbtResourceType) }, - dbt_deps=True, ) project_config = ProjectConfig( @@ -85,5 +84,8 @@ def convert_exposure(dag: DAG, task_group: TaskGroup, node: DbtNode, **kwargs): start_date=datetime(2023, 1, 1), catchup=False, dag_id="example_cosmos_sources", + operator_args={ + "install_deps": True, + }, ) # [END custom_dbt_nodes]