@@ -31,7 +31,7 @@ class Rufus::Scheduler |
||
31 | 31 |
# Get a job tied to a given SchedulerAgent |
32 | 32 |
def scheduler_agent_job(agent) |
33 | 33 |
scheduler_agent_jobs.find { |job| |
34 |
- job[:scheduler_agent_id] == agent.id |
|
34 |
+ job.scheduler_agent_id == agent.id |
|
35 | 35 |
} |
36 | 36 |
end |
37 | 37 |
|
@@ -67,6 +67,9 @@ class Rufus::Scheduler |
||
67 | 67 |
job.unschedule |
68 | 68 |
end |
69 | 69 |
end |
70 |
+ # Make sure the job is associated with a SchedulerAgent before |
|
71 |
+ # it is triggered. |
|
72 |
+ job.scheduler_agent_id = agent_id |
|
70 | 73 |
|
71 | 74 |
agent.memory['scheduled_at'] = job.scheduled_at.to_i |
72 | 75 |
agent.save |