diff --git a/django_q/cluster.py b/django_q/cluster.py
index cc5cbff..503ef71 100644
--- a/django_q/cluster.py
+++ b/django_q/cluster.py
@@ -620,7 +620,7 @@ def scheduler(broker: Broker = None):
                                     )
                                 )
                             next_run = arrow.get(
-                                croniter(s.cron, timezone.now()).get_next()
+                                croniter(s.cron, timezone.localtime()).get_next()
                             )
                         if Conf.CATCH_UP or next_run > arrow.utcnow():
                             break