| 277 | self.update_from_dict(entries) |
| 278 | |
| 279 | def apply_entry(self, entry, producer=None): |
| 280 | info('Scheduler: Sending due task %s (%s)', entry.name, entry.task) |
| 281 | try: |
| 282 | result = self.apply_async(entry, producer=producer, advance=False) |
| 283 | except Exception as exc: # pylint: disable=broad-except |
| 284 | error('Message Error: %s\n%s', |
| 285 | exc, traceback.format_stack(), exc_info=True) |
| 286 | else: |
| 287 | if result and hasattr(result, 'id'): |
| 288 | debug('%s sent. id->%s', entry.task, result.id) |
| 289 | else: |
| 290 | debug('%s sent.', entry.task) |
| 291 | |
| 292 | def adjust(self, n, drift=-0.010): |
| 293 | if n and n > 0: |