fix: update PeriodicTask from entry (celery#344)

petrprikryl · Oct 17, 2022 · 87e845a · 87e845a
1 parent 6b67b24
commit 87e845a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/django_celery_beat/schedulers.py b/django_celery_beat/schedulers.py
@@ -175,9 +175,13 @@ def from_entry(cls, name, app=None, **entry):
     def _unpack_fields(cls, schedule,
                        args=None, kwargs=None, relative=None, options=None,
                        **entry):
+        entry_schedules = {
+            model_field: None for _, _, model_field in cls.model_schedules
+        }
         model_schedule, model_field = cls.to_model_schedule(schedule)
+        entry_schedules[model_field] = model_schedule
         entry.update(
-            {model_field: model_schedule},
+            entry_schedules,
             args=dumps(args or []),
             kwargs=dumps(kwargs or {}),
             **cls._unpack_options(**options or {})