Bug: Invalid MySQL query using version 2.8.1 #922
Description
I am using these components:
celery5.4.0django-celery-beat2.8.1django-celery-results2.6.0django5.2- MySQL 5.7.44
- Python 3.12.8
and can observe errors when starting up Celery Beat and having at least one periodic task active. This error did not get raised in 2.8.0.
Steps to reproduce:
- Have a basic Django setup
- Start MySQL
- Run Django migrations:
./manage.py migrate - Start Beat:
celery -A myapp beat --scheduler django_celery_beat.schedulers:DatabaseSchedulerto create thecelery.backend_cleanuptask - Stop and restart Beat
- Observe this error:
...
[2025-07-28 15:11:14,380: WARNING/MainProcess] raise get_mysql_exception(
[2025-07-28 15:11:14,380: WARNING/MainProcess] django.db.utils
[2025-07-28 15:11:14,380: WARNING/MainProcess] .
[2025-07-28 15:11:14,380: WARNING/MainProcess] ProgrammingError
[2025-07-28 15:11:14,380: WARNING/MainProcess] :
[2025-07-28 15:11:14,380: WARNING/MainProcess] (1064, "1064 (42000): You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near '% 24) ELSE CAST(U0.`hour` AS signed integer) END IN (13, 14, 15, 16, 17, 4)))) A' at line 1", '42000')
Using the general query log and --log-raw option of MySQL I identified the issue in this SQL query:
SELECT
`django_celery_beat_periodictask`.`id`,
`django_celery_beat_periodictask`.`name`,
`django_celery_beat_periodictask`.`task`,
`django_celery_beat_periodictask`.`interval_id`,
`django_celery_beat_periodictask`.`crontab_id`,
`django_celery_beat_periodictask`.`solar_id`,
`django_celery_beat_periodictask`.`clocked_id`,
`django_celery_beat_periodictask`.`args`,
`django_celery_beat_periodictask`.`kwargs`,
`django_celery_beat_periodictask`.`queue`,
`django_celery_beat_periodictask`.`exchange`,
`django_celery_beat_periodictask`.`routing_key`,
`django_celery_beat_periodictask`.`headers`,
`django_celery_beat_periodictask`.`priority`,
`django_celery_beat_periodictask`.`expires`,
`django_celery_beat_periodictask`.`expire_seconds`,
`django_celery_beat_periodictask`.`one_off`,
`django_celery_beat_periodictask`.`start_time`,
`django_celery_beat_periodictask`.`enabled`,
`django_celery_beat_periodictask`.`last_run_at`,
`django_celery_beat_periodictask`.`total_run_count`,
`django_celery_beat_periodictask`.`date_changed`,
`django_celery_beat_periodictask`.`description`
FROM
`django_celery_beat_periodictask`
LEFT OUTER JOIN `django_celery_beat_clockedschedule` ON
(`django_celery_beat_periodictask`.`clocked_id` = `django_celery_beat_clockedschedule`.`id`)
WHERE
(`django_celery_beat_periodictask`.`enabled` = 1
AND NOT (((`django_celery_beat_clockedschedule`.`clocked_time` > '2025-07-29 14:05:32.092804'
AND `django_celery_beat_clockedschedule`.`clocked_time` IS NOT NULL
AND `django_celery_beat_periodictask`.`clocked_id` IS NOT NULL)
OR (`django_celery_beat_periodictask`.`crontab_id` IS NOT NULL
AND `django_celery_beat_periodictask`.`crontab_id` IN (
SELECT
U0.`id` AS `id`
FROM
`django_celery_beat_crontabschedule` U0
WHERE
(U0.`hour` REGEXP BINARY '^\\d+$'
AND NOT (CASE
WHEN (U0.`timezone` = 'UTC') THEN (((CAST(U0.`hour` AS signed integer) + 0) + 24) %% 24)
ELSE CAST(U0.`hour` AS signed integer)
END IN (12, 13, 14, 15, 16, 4))))
AND `django_celery_beat_periodictask`.`crontab_id` IS NOT NULL))))Notice the double %% being semantically incorrect, its meant to be a single %. This seems to stem from
% to %% is happening.