Skip to content

Instantly share code, notes, and snippets.

@orenmazor
Created February 6, 2013 20:53
Show Gist options
  • Save orenmazor/4725725 to your computer and use it in GitHub Desktop.
Save orenmazor/4725725 to your computer and use it in GitHub Desktop.
class ETLJob
include Sidekiq::Worker
sidekiq_options :queue => :ETLTasks, :backtrace => true, :retry => false
def perform(control_file)
ETL::Engine.init({:execution_dbname=>"etl_execution_prod"})
ETL::Engine.process("#{Dir.pwd}/control/#{control_file}.ctl")
end
end
class ETLTimeDimensionJob < ETLJob
def perform
StatsD.measure("ETLJob.perform.time_dimension") do
super("prepare_time_dimension")
end
end
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment