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) }