Update app.py

app.py

@@ -74,11 +74,16 @@ def create_plan(account, limit):
 def apply_plan():
     now = datetime.now(tz)
     count = 0
+
     for plan in plans.find():
-        plan_time = datetime.fromisoformat(plan["scheduled_time"]).astimezone(tz)
-        if plan_time > now:
+        try:
+            plan_time = datetime.fromisoformat(plan["scheduled_time"]).astimezone(tz)
+            if plan_time <= now:
+                continue  # Skip past plans
+
             account = accounts.find_one({"_id": plan["account_id"]})
             if not account:
+                print(f"⚠️ No account found for plan {plan['_id']}")
                 continue
 
             userbot = userbots.get(account["user_id"])
@@ -86,19 +91,27 @@ def apply_plan():
                 print(f"⚠️ No userbot for account {account['_id']}, skipping...")
                 continue
 
+            async def job_wrapper(ub=userbot, acc=account, pl=plan):
+                await auto_create_groups(ub, acc, pl)
+
             job_id = f"job_{plan['_id']}"
             scheduler.add_job(
-                lambda ub=userbot, acc=account, pl=plan: asyncio.run(
-                    auto_create_groups(ub, acc, pl)
-                ),
+                job_wrapper,
                 trigger='date',
                 run_date=plan_time,
-                id=job_id
+                id=job_id,
+                name=f"AutoGroupPlan_{account['_id']}"
             )
+
             print(f"📌 Scheduled job for account {account['_id']} at {plan_time.strftime('%H:%M:%S')} (ID: {job_id})")
             count += 1
+
+        except Exception as e:
+            print(f"❌ Error scheduling plan {plan.get('_id')}: {e}")
+
     print(f"✅ Applied and scheduled {count} job(s).")
 
+
 def reset_and_plan():
     print("🔁 Resetting plans and scheduling new ones...")
     plans.delete_many({})