Relative Content

Tag Archive for pythondjangocelery

Why celery beat scheduler still running after expires in django celery

PeriodicTask.objects.create( interval=interval, crontab=crontab, clocked=clocked, name=data[“name”], task=data[“task”], # dropdown args=json.dumps(json.loads(data[“args”])), one_off=True if schedule_type == “clocked” else False, expires=datetime.strptime(data[“expires”], ‘%Y-%m-%d %H:%M:%S.%f’) if data[“expires”] else None ) -its still running after set expires time -its not calling function but its hit worker ex: in worker terminal [2024-07-22 07:06:16,334: INFO/MainProcess] Task test[390404a1-9814-4208-85a2-6e1269bc09d9] received [2024-07-22 07:06:16,334: INFO/MainProcess] Discarding revoked task: […]