Cross Reference: timeout_worker.rb
xref: /ontohub/lib/timeout_worker.rb
  • Home
  • History
  • Annotate
  • Line#
  • Navigate
  • Download
  • only in ./
timeout_worker.rb revision 1a7c903d7c95e94f306f7a41de9f6d607448dbe3
1516N/Aclass TimeoutWorker < BaseWorker
581N/A class Error < ::StandardError; end
581N/A class TimeOutNotSetError < Error; end
581N/A
581N/A RESCHEDULE_TIME = 30 # minutes
581N/A
581N/A sidekiq_options queue: 'default'
581N/A
581N/A def self.start_timeout_clock(ontology_version_id, hours_offset=nil)
581N/A hours_offset ||= timeout_limit
581N/A self.perform_in(hours_offset.hours, ontology_version_id)
581N/A end
581N/A
581N/A def self.timeout_limit
581N/A raise TimeOutNotSetError unless Settings.ontology_parse_timeout
581N/A Settings.ontology_parse_timeout
581N/A end
581N/A
581N/A
581N/A def perform(ontology_version_id)
581N/A version = OntologyVersion.find(ontology_version_id)
581N/A if state_not_terminal?(version)
1899N/A version.update_state!('failed', "The job reached the timeout limit of #{self.class.timeout_limit} hours.")
1895N/A end
1899N/A end
581N/A
581N/A def state_not_terminal?(ontology_version)
581N/A !(ontology_version.state == 'failed' || ontology_version.state == 'done')
817N/A end
1715N/A
581N/Aend
742N/A

Indexes created Tue Jul 24 14:28:13 CEST 2018