|
@@ -178,7 +178,7 @@ class Scheduler(UserDict):
|
|
|
return min(remaining_times + [self.max_interval])
|
|
|
|
|
|
def reserve(self, entry):
|
|
|
- new_entry = self[entry.name] = entry.next()
|
|
|
+ new_entry = self.schedule[entry.name] = entry.next()
|
|
|
return new_entry
|
|
|
|
|
|
def apply_async(self, entry, connection=None, **kwargs):
|
|
@@ -209,7 +209,7 @@ class Scheduler(UserDict):
|
|
|
|
|
|
def add(self, **kwargs):
|
|
|
entry = self.Entry(**kwargs)
|
|
|
- self[entry.name] = entry
|
|
|
+ self.schedule[entry.name] = entry
|
|
|
return entry
|
|
|
|
|
|
def update_from_dict(self, dict_):
|