This commit is contained in:
yasir 2023-02-27 11:52:55 +07:00
parent 6fba574298
commit 641453eba5
2 changed files with 7 additions and 6 deletions

View file

@ -4,6 +4,7 @@ import logging
from logging import ERROR, INFO, FileHandler, StreamHandler, basicConfig, getLogger from logging import ERROR, INFO, FileHandler, StreamHandler, basicConfig, getLogger
import pyromod.listen import pyromod.listen
from apscheduler.schedulers.asyncio import AsyncIOScheduler
from apscheduler.jobstores.mongodb import MongoDBJobStore from apscheduler.jobstores.mongodb import MongoDBJobStore
from pymongo import MongoClient from pymongo import MongoClient
from pyrogram import Client from pyrogram import Client
@ -46,6 +47,10 @@ jobstores = {
database="MissKatyDB", database="MissKatyDB",
collection='nightmode')} collection='nightmode')}
scheduler = AsyncIOScheduler(
jobstores=jobstores,
timezone=TZ)
app.start() app.start()
user.start() user.start()
bot = app.get_me() bot = app.get_me()

View file

@ -18,15 +18,13 @@ from pyrogram.raw.all import layer
from pyrogram.types import InlineKeyboardButton, InlineKeyboardMarkup from pyrogram.types import InlineKeyboardButton, InlineKeyboardMarkup
from database.users_chats_db import db from database.users_chats_db import db
from apscheduler.schedulers.asyncio import AsyncIOScheduler
from misskaty import ( from misskaty import (
BOT_NAME, BOT_NAME,
BOT_USERNAME, BOT_USERNAME,
HELPABLE, HELPABLE,
UBOT_NAME, UBOT_NAME,
TZ,
app, app,
jobstores scheduler
) )
from misskaty.core.message_utils import * from misskaty.core.message_utils import *
from misskaty.core.decorator.ratelimiter import ratelimiter from misskaty.core.decorator.ratelimiter import ratelimiter
@ -73,9 +71,7 @@ async def start_bot():
) )
except Exception as e: except Exception as e:
LOGGER.error(str(e)) LOGGER.error(str(e))
scheduler = AsyncIOScheduler( scheduler.start()
jobstores=jobstores,
timezone=TZ)
LOGGER.info(scheduler.get_jobs()) LOGGER.info(scheduler.get_jobs())
if bool(scheduler.get_jobs()): if bool(scheduler.get_jobs()):
scheduler.start() scheduler.start()