Sha256: 1fb4d1f29c7367f5880221d6130fba8c9ba021370cbb4fde4d70f2a0c37d3c57
Contents?: true
Size: 1.34 KB
Versions: 5
Compression:
Stored size: 1.34 KB
Contents
module AnswersEngine
module Client
class Job < AnswersEngine::Client::Base
def all(opts={})
self.class.get("/jobs", @options)
end
def find(job_id)
self.class.get("/jobs/#{job_id}", @options)
end
def update(job_id, opts={})
body = {}
body[:status] = opts[:status] if opts[:status]
body[:standard_worker_count] = opts[:workers] if opts[:workers]
body[:browser_worker_count] = opts[:browsers] if opts[:browsers]
@options.merge!({body: body.to_json})
self.class.put("/jobs/#{job_id}", @options)
end
def cancel(job_id, opts={})
opts[:status] = 'cancelled'
update(job_id, opts)
end
def resume(job_id, opts={})
opts[:status] = 'active'
update(job_id, opts)
end
def pause(job_id, opts={})
opts[:status] = 'paused'
update(job_id, opts)
end
def seeding_update(job_id, opts={})
body = {}
body[:outputs] = opts.fetch(:outputs) {[]}
body[:pages] = opts.fetch(:pages) {[]}
body[:seeding_status] = opts.fetch(:seeding_status){ nil }
body[:log_error] = opts[:log_error] if opts[:log_error]
@options.merge!({body: body.to_json})
self.class.put("/jobs/#{job_id}/seeding_update", @options)
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems