Method: Funktor::WorkQueueHandler#trigger_retry

Defined in:
lib/funktor/work_queue_handler.rb

#trigger_retry(job) ⇒ Object 



70
71
72
73
74
75
76
77
78
 
# File 'lib/funktor/work_queue_handler.rb', line 70

def trigger_retry(job)
  job.increment_retries
  Funktor.logger.error "scheduling retry # #{job.retries} with delay of #{job.delay}"
  Funktor.logger.error job.to_json
  sqs_client.send_message({
    queue_url: job.retry_queue_url,
    message_body: job.to_json
  })
end