Class: SimpleMapReduce::Worker::RegisterMapTaskWorker

Inherits:
Object
  • Object
show all
Defined in:
lib/simple_map_reduce/worker/register_map_task_worker.rb

Instance Method Summary collapse

Instance Method Details

#perform(job) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/simple_map_reduce/worker/register_map_task_worker.rb', line 6

def perform(job)
  logger.info('register map task worker start!')
  client = http_client(job.map_worker.url)
  response = client.post do |request|
    request.url('/map_tasks')
    request.body = job.serialize
  end
  logger.debug(response.body)
rescue => e
  logger.error(e.inspect)
  logger.error(e.backtrace.take(50))
  SimpleMapReduce::Server::JobTracker.store_worker(job.map_worker)
  job.failed!
end