fix _get_distinct_timezone

the previous query did not actually get distinct timezones

Author: beedub

django_celery_beat/schedulers.py

@@ -23,8 +23,14 @@
 from kombu.utils.json import dumps, loads
 
 from .clockedschedule import clocked
-from .models import (ClockedSchedule, CrontabSchedule, IntervalSchedule,
-                     PeriodicTask, PeriodicTasks, SolarSchedule)
+from .models import (
+    ClockedSchedule,
+    CrontabSchedule,
+    IntervalSchedule,
+    PeriodicTask,
+    PeriodicTasks,
+    SolarSchedule,
+)
 from .utils import NEVER_CHECK_TIMEOUT, aware_now, now
 
 # This scheduler must wake up more frequently than the
@@ -340,7 +346,7 @@ def _get_crontab_exclude_query(self):
                             + 24
                         ) % 24
                     )
-                    for timezone_name in self._get_unique_timezone_names()
+                    for timezone_name in self._get_unique_timezones()
                 ],
                 # Default case - use hour as is
                 default=F('hour_int')
@@ -359,11 +365,11 @@ def _get_crontab_exclude_query(self):
 
         return exclude_query
 
-    def _get_unique_timezone_names(self):
-        """Get a list of all unique timezone names used in CrontabSchedule"""
-        return CrontabSchedule.objects.values_list(
-            'timezone', flat=True
-        ).distinct()
+    def _get_unique_timezones(self):
+        """Get a list of all unique timezones used in CrontabSchedule"""
+        return list(
+            CrontabSchedule.objects.order_by('timezone').distinct('timezone').values_list('timezone', flat=True)
+        )
 
     def _get_timezone_offset(self, timezone_name):
         """

t/unit/test_schedulers.py

@@ -1059,6 +1059,23 @@ def test_crontab_special_hour_four(self):
         # The hour=4 task should never be excluded
         assert task_hour_four.id not in excluded_tasks
 
+    @pytest.mark.django_db
+    def test_crontab_special_hour_four(self):
+        """
+        Test that schedules with hour=4 are always included, regardless of
+        the current time.
+        """
+        # Create 2 crontabs with same timezone, and 1 with different timezone
+        CrontabSchedule.objects.create(hour='4', timezone='UTC')
+        CrontabSchedule.objects.create(hour='4', timezone='UTC')
+        CrontabSchedule.objects.create(hour='4', timezone='America/New_York')
+
+        # Run the scheduler's exclusion logic
+        timezones = self.s._get_unique_timezones()
+
+        assert len(timezones) == 2
+        assert set(timezones) == {ZoneInfo('UTC'), ZoneInfo('America/New_York')}
+
     @pytest.mark.django_db
     @patch('django_celery_beat.schedulers.aware_now')
     @patch('django.utils.timezone.get_current_timezone')