class Blazer::RunStatementJob
Public Instance Methods
perform(data_source_id, statement, options)
click to toggle source
# File lib/blazer/run_statement_job.rb, line 5 def perform(data_source_id, statement, options) data_source = Blazer.data_sources[data_source_id] begin ActiveRecord::Base.connection_pool.with_connection do Blazer::RunStatement.new.perform(data_source, statement, options) end rescue Exception => e Blazer::Result.new(data_source, [], [], "Unknown error", nil, false) Blazer.cache.write(data_source.run_cache_key(options[:run_id]), Marshal.dump([[], [], "Unknown error", nil]), expires_in: 30.seconds) raise e end end