diff --git a/integrations/Gemfile.lock b/integrations/Gemfile.lock index 52c85fbc..d7fb41ae 100644 --- a/integrations/Gemfile.lock +++ b/integrations/Gemfile.lock @@ -7,7 +7,7 @@ GIT PATH remote: . specs: - multiwoven-integrations (0.15.8) + multiwoven-integrations (0.15.9) MailchimpMarketing activesupport async-websocket diff --git a/integrations/lib/multiwoven/integrations/core/utils.rb b/integrations/lib/multiwoven/integrations/core/utils.rb index e1078f70..03efb91d 100644 --- a/integrations/lib/multiwoven/integrations/core/utils.rb +++ b/integrations/lib/multiwoven/integrations/core/utils.rb @@ -61,11 +61,11 @@ def log_request_response(level, request, response) ) end - def create_log_message(context, type, exception) + def create_log_message(context, type, message) Integrations::Protocol::LogMessage.new( name: context, level: type, - message: exception.message + message: message ).to_multiwoven_message end @@ -74,7 +74,7 @@ def handle_exception(exception, meta = {}) "#{hash_to_string(meta)}: #{exception.message}" ) report_exception(exception, meta) - create_log_message(meta[:context], meta[:type], exception) + create_log_message(meta[:context], meta[:type], exception.message) end def hash_to_string(hash) diff --git a/integrations/lib/multiwoven/integrations/rollout.rb b/integrations/lib/multiwoven/integrations/rollout.rb index ff6c24ae..6450b0d4 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.15.8" + VERSION = "0.15.9" ENABLED_SOURCES = %w[ Snowflake diff --git a/integrations/lib/multiwoven/integrations/source/databrics_model/client.rb b/integrations/lib/multiwoven/integrations/source/databrics_model/client.rb index e9acbf94..9132d001 100644 --- a/integrations/lib/multiwoven/integrations/source/databrics_model/client.rb +++ b/integrations/lib/multiwoven/integrations/source/databrics_model/client.rb @@ -65,7 +65,7 @@ def process_response(response) data = JSON.parse(response.body) [RecordMessage.new(data: data, emitted_at: Time.now.to_i).to_multiwoven_message] else - create_log_message("DATABRICKS MODEL:RUN_MODEL", "error", "request failed") + create_log_message("DATABRICKS MODEL:RUN_MODEL", "error", "request failed: #{response.body}") end end diff --git a/integrations/lib/multiwoven/integrations/source/http_model/client.rb b/integrations/lib/multiwoven/integrations/source/http_model/client.rb index 3a100c63..e5c8c045 100644 --- a/integrations/lib/multiwoven/integrations/source/http_model/client.rb +++ b/integrations/lib/multiwoven/integrations/source/http_model/client.rb @@ -72,7 +72,7 @@ def process_response(response) data = JSON.parse(response.body) [RecordMessage.new(data: data, emitted_at: Time.now.to_i).to_multiwoven_message] else - create_log_message("HTTP MODEL:RUN_MODEL", "error", "request failed") + create_log_message("HTTP MODEL:RUN_MODEL", "error", "request failed: #{response.body}") end end