Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- include Sidekiq::Worker
- include Sidekiq::Status::Worker
- sidekiq_options queue: :flight_parser, backtrace: true, retry: 3
- def expiration
- @expiration ||= 60*60*24*30 # 30 days
- end
- def update_progress_status
- at @status, status_message
- @status += @step
- end
- def set_progress_status_and_step(num_of_elements)
- @step = calculate_progress_step(num_of_elements)
- @status = @step
- end
- require 'sidekiq'
- require 'sidekiq-status'
- Sidekiq.configure_client do |config|
- config.redis = { :size => 1 }
- # accepts :expiration (optional)
- Sidekiq::Status.configure_client_middleware config, expiration: 30.minutes
- end
- Sidekiq.configure_server do |config|
- # accepts :expiration (optional)
- Sidekiq::Status.configure_server_middleware config, expiration: 30.minutes
- # accepts :expiration (optional)
- Sidekiq::Status.configure_client_middleware config, expiration: 30.minutes
- end
- Redis.current = Redis.new(:host => '127.0.0.1', :port => 6379)
Add Comment
Please, Sign In to add comment