lib/gush/client.rb in gush-0.2.2 vs lib/gush/client.rb in gush-0.2.3
- old
+ new
@@ -85,13 +85,14 @@
def persist_job(workflow_id, job)
redis.set("gush.jobs.#{workflow_id}.#{job.class.to_s}", job.to_json)
end
def load_job(workflow_id, job_id)
+ workflow = find_workflow(workflow_id)
data = redis.get("gush.jobs.#{workflow_id}.#{job_id}")
return nil if data.nil?
data = Gush::JSON.decode(data, symbolize_keys: true)
- Gush::Job.from_hash(nil, data)
+ Gush::Job.from_hash(workflow, data)
end
def destroy_workflow(workflow)
redis.del("gush.workflows.#{workflow.id}")
workflow.jobs.each {|job| destroy_job(workflow.id, job) }