5
6
7
8
9
10
11
12
13
14
15
16
|
# 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
|