(self, schedule, sig,
args=(), kwargs=None, name=None, **opts)
| 1224 | return key |
| 1225 | |
| 1226 | def _sig_to_periodic_task_entry(self, schedule, sig, |
| 1227 | args=(), kwargs=None, name=None, **opts): |
| 1228 | kwargs = {} if not kwargs else kwargs |
| 1229 | sig = (sig.clone(args, kwargs) |
| 1230 | if isinstance(sig, abstract.CallableSignature) |
| 1231 | else self.signature(sig.name, args, kwargs)) |
| 1232 | return name or repr(sig), { |
| 1233 | 'schedule': schedule, |
| 1234 | 'task': sig.name, |
| 1235 | 'args': sig.args, |
| 1236 | 'kwargs': sig.kwargs, |
| 1237 | 'options': dict(sig.options, **opts), |
| 1238 | } |
| 1239 | |
| 1240 | def _add_periodic_task(self, key, entry, name=None): |
| 1241 | if name is None and key in self._conf.beat_schedule: |
no test coverage detected