PersonalPublic/mosgortrans
1
0
Fork 0
mirror of https://github.com/Balshgit/mosgortrans.git synced 2025-09-11 13:00:40 +03:00
Code Issues Packages Projects Releases Wiki Activity

cron to top of file

Browse Source
This commit is contained in:
Dmitry Afanasyev 2022-08-08 20:53:17 +03:00
parent 93df38f03d
commit 7f5655e198
1 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
main.py
View File

@ -16,9 +16,9 @@ dispatcher = Dispatcher(bot)
dispatcher.middleware.setup(LoggingMiddleware()) dispatcher.middleware.setup(LoggingMiddleware())
cron_jobs = [ cron_jobs = [
{'trigger': 'cron', 'day_of_week': 'mon-fri', 'hour': 20, 'minute': 50, 'second': 10}, {'trigger': 'cron', 'day_of_week': 'mon-fri', 'hour': 20, 'minute': 53, 'second': 40},
{'trigger': 'cron', 'day_of_week': 'mon-fri', 'hour': 20, 'minute': 51, 'second': 10}, {'trigger': 'cron', 'day_of_week': 'mon-fri', 'hour': 20, 'minute': 54, 'second': 10},
{'trigger': 'cron', 'day_of_week': 'mon-fri', 'hour': 20, 'minute': 52, 'second': 10}, {'trigger': 'cron', 'day_of_week': 'mon-fri', 'hour': 20, 'minute': 55, 'second': 10},
] ]
user_chat_ids = {'chat_ids': [417070387, user_chat_ids = {'chat_ids': [417070387,
@ -98,12 +98,8 @@ def asyncio_schedule() -> None:
from apscheduler.schedulers.asyncio import AsyncIOScheduler from apscheduler.schedulers.asyncio import AsyncIOScheduler
scheduler = AsyncIOScheduler() scheduler = AsyncIOScheduler()
scheduler.add_job(send_message, kwargs=user_chat_ids, for cron in cron_jobs:
trigger='cron', day_of_week='mon-fri', hour=20, minute=40, second=10) scheduler.add_job(send_message, **cron)
scheduler.add_job(send_message, kwargs=user_chat_ids,
trigger='cron', day_of_week='mon-fri', hour=20, minute=43, second=20)
scheduler.add_job(send_message, kwargs=user_chat_ids,
trigger='cron', day_of_week='mon-fri', hour=20, minute=45, second=42)
scheduler.start() scheduler.start()
@ -119,8 +115,8 @@ async def on_shutdown(dispatcher):
await bot.delete_webhook() await bot.delete_webhook()
# Close DB connection (if used) # Close DB connection (if used)
await dp.storage.close() await dispatcher.storage.close()
await dp.storage.wait_closed() await dispatcher.storage.wait_closed()
logger.warning('Bye!') logger.warning('Bye!')