diff --git a/integrations/lib/multiwoven/integrations/protocol/protocol.rb b/integrations/lib/multiwoven/integrations/protocol/protocol.rb index 22fcdfbb..6595b619 100644 --- a/integrations/lib/multiwoven/integrations/protocol/protocol.rb +++ b/integrations/lib/multiwoven/integrations/protocol/protocol.rb @@ -11,7 +11,7 @@ module Types DestinationSyncMode = Types::String.enum("insert", "upsert") ConnectorType = Types::String.enum("source", "destination") ConnectorQueryType = Types::String.enum("raw_sql", "soql", "ai_ml") - ModelQueryType = Types::String.enum("raw_sql", "dbt", "soql", "table_selector", "ai_ml") + ModelQueryType = Types::String.enum("raw_sql", "dbt", "soql", "table_selector", "ai_ml", "dynamic_sql") ConnectionStatusType = Types::String.enum("succeeded", "failed") StreamType = Types::String.enum("static", "dynamic", "user_defined") StreamAction = Types::String.enum("fetch", "create", "update", "delete") diff --git a/integrations/lib/multiwoven/integrations/rollout.rb b/integrations/lib/multiwoven/integrations/rollout.rb index 26ea3a0e..2cb81bb7 100644 --- a/integrations/lib/multiwoven/integrations/rollout.rb +++ b/integrations/lib/multiwoven/integrations/rollout.rb @@ -2,7 +2,7 @@ module Multiwoven module Integrations - VERSION = "0.14.0" + VERSION = "0.14.1" ENABLED_SOURCES = %w[ Snowflake diff --git a/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb b/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb index f0d2c640..10192c99 100644 --- a/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb +++ b/integrations/spec/multiwoven/integrations/protocol/protocol_spec.rb @@ -383,6 +383,11 @@ module Integrations::Protocol model = Model.new(name: "Test", query: "SELECT * FROM table", query_type: "ai_ml", primary_key: "id") expect("ai_ml").to include(model.query_type) end + + it "has a query_type 'dynamic_sql'" do + model = Model.new(name: "Test", query: "SELECT * FROM table", query_type: "dynamic_sql", primary_key: "id") + expect("dynamic_sql").to include(model.query_type) + end end end