Add a periodic task to beat schedule. Celery beat store tasks based on `sig` or `name` if provided. Adding the same signature twice make the second task override the first one. To avoid the override, use distinct `name` for them.
(self, schedule, sig,
args=(), kwargs=(), name=None, **opts)
| 1207 | return self._canvas.signature(*args, **kwargs) |
| 1208 | |
| 1209 | def add_periodic_task(self, schedule, sig, |
| 1210 | args=(), kwargs=(), name=None, **opts): |
| 1211 | """ |
| 1212 | Add a periodic task to beat schedule. |
| 1213 | |
| 1214 | Celery beat store tasks based on `sig` or `name` if provided. Adding the |
| 1215 | same signature twice make the second task override the first one. To |
| 1216 | avoid the override, use distinct `name` for them. |
| 1217 | """ |
| 1218 | key, entry = self._sig_to_periodic_task_entry( |
| 1219 | schedule, sig, args, kwargs, name, **opts) |
| 1220 | if self.configured: |
| 1221 | self._add_periodic_task(key, entry, name=name) |
| 1222 | else: |
| 1223 | self._pending_periodic_tasks.append([(key, entry), {"name": name}]) |
| 1224 | return key |
| 1225 | |
| 1226 | def _sig_to_periodic_task_entry(self, schedule, sig, |
| 1227 | args=(), kwargs=None, name=None, **opts): |