(self, app, schedule=None, max_interval=None,
Producer=None, lazy=False, sync_every_tasks=None, **kwargs)
| 250 | logger = logger # compat |
| 251 | |
| 252 | def __init__(self, app, schedule=None, max_interval=None, |
| 253 | Producer=None, lazy=False, sync_every_tasks=None, **kwargs): |
| 254 | self.app = app |
| 255 | self.data = maybe_evaluate({} if schedule is None else schedule) |
| 256 | self.max_interval = (max_interval or |
| 257 | app.conf.beat_max_loop_interval or |
| 258 | self.max_interval) |
| 259 | self.Producer = Producer or app.amqp.Producer |
| 260 | self._heap = None |
| 261 | self.old_schedulers = None |
| 262 | self.sync_every_tasks = ( |
| 263 | app.conf.beat_sync_every if sync_every_tasks is None |
| 264 | else sync_every_tasks) |
| 265 | if not lazy: |
| 266 | self.setup_schedule() |
| 267 | |
| 268 | def install_default_entries(self, data): |
| 269 | entries = {} |
nothing calls this directly
no test coverage detected