diff --git a/app/run_scheduler.py b/app/run_scheduler.py
index 1d4f9f3..5f1779e 100644
--- a/app/run_scheduler.py
+++ b/app/run_scheduler.py
@@ -26,26 +26,23 @@ def main(dry_run: bool = False):
             max_instances=1,
             replace_existing=True,
         )
-        if not SCHEDULER.get_job("refresh_user_credits", jobstore="db"):
-            logger.info(
-                f"Adding monthly refresh_user_credits to scheduler: trigger = {MONTHLY_TRIGGER}"
-            )
-            logger.info(
-                f"Next refresh at: {MONTHLY_TRIGGER.get_next_fire_time(previous_fire_time=None, now=datetime.now(tz=UTC))}"
-            )
-            SCHEDULER.add_job(
-                refresh_user_credits,
-                kwargs={"dry_run": dry_run},
-                jobstore="db",
-                trigger=MONTHLY_TRIGGER,
-                id="refresh_user_credits",
-                misfire_grace_time=60 * 60 * 24,
-                max_instances=1,
-                replace_existing=False,
-                coalesce=True,
-            )
-        else:
-            logger.info("Monthly refresh_user_credits already exists in scheduler")
+        logger.info(
+            f"Adding monthly refresh_user_credits to scheduler: trigger = {MONTHLY_TRIGGER}"
+        )
+        logger.info(
+            f"Next refresh at: {MONTHLY_TRIGGER.get_next_fire_time(previous_fire_time=None, now=datetime.now(tz=UTC))}"
+        )
+        SCHEDULER.add_job(
+            refresh_user_credits,
+            kwargs={"dry_run": dry_run},
+            jobstore="db",
+            trigger=MONTHLY_TRIGGER,
+            id="refresh_user_credits",
+            misfire_grace_time=60 * 60 * 24,
+            max_instances=1,
+            replace_existing=True,
+            coalesce=True,
+        )
         logger.info("Starting scheduler")
         SCHEDULER.start()
     finally: