diff --git a/dbt/include/risingwave/macros/adapters.sql b/dbt/include/risingwave/macros/adapters.sql index 558ed63..eb3e665 100644 --- a/dbt/include/risingwave/macros/adapters.sql +++ b/dbt/include/risingwave/macros/adapters.sql @@ -117,5 +117,9 @@ {%- endmacro %} {% macro risingwave__run_sql(sql) -%} + {% set contract_config = config.get('contract') %} + {% if contract_config.enforced %} + {{exceptions.warn("Model contracts cannot be enforced for source, table_with_connector and sink")}} + {%- endif %} {{ sql }}; {%- endmacro %}