(self, entry)
| 387 | ) |
| 388 | |
| 389 | def reserve(self, entry): |
| 390 | new_entry = self.schedule[entry.name] = next(entry) |
| 391 | return new_entry |
| 392 | |
| 393 | def apply_async(self, entry, producer=None, advance=True, **kwargs): |
| 394 | # Update time-stamps and run counts before we actually execute, |
no outgoing calls
no test coverage detected