apscheduler

app.py

@@ -8,6 +8,8 @@ from slack_sdk.errors import SlackApiError
 import aiojobs
 import asyncio
 from datetime import datetime, timedelta
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
+
 
 DISCORD_TOKEN = os.getenv('DISCORD_TOKEN')
 SLACK_BOT_TOKEN = os.getenv('BOT_USER_OAUTH_TOKEN_HF')
@@ -141,11 +143,6 @@ def post_to_slack_create_thread(channel, text, thread_ts=None):
         return None        
 
 #----------------------------------------------------------------------------------------------
-async def collect_pings():
-    await bot.wait_until_ready()
-    while not bot.is_closed():
-        await aiojobs.create_scheduler().spawn(send_daily_pings())
-        await asyncio.sleep(60)
 
 async def send_daily_pings():
     global daily_pings
@@ -155,11 +152,6 @@ async def send_daily_pings():
         await post_to_slack(None, combined_message, SLACK_CHANNEL_ID_TEST, None, None, None)
         daily_pings = []  # reset after posting
 
-
-
-
-
-
 # pings -------------------------------------------------------------------------------------------
 
 async def post_to_slack(author, content, channel, url, slack_mention, trigger):
@@ -172,15 +164,15 @@ async def post_to_slack(author, content, channel, url, slack_mention, trigger):
         print(f"Error posting to Slack: {e.response['error']}")
 
 
+scheduler = AsyncIOScheduler()
+scheduler.add_job(send_daily_pings, 'interval', minutes=1)
+scheduler.start()
+
+
 # runs discord bot in thread = helps avoid blocking calls
-async def run_bot():
-    bot.loop.create_task(collect_pings())
-    await bot.start(DISCORD_TOKEN)
-def start_bot_thread():
-    loop = asyncio.new_event_loop()
-    asyncio.set_event_loop(loop)
-    loop.run_until_complete(run_bot())
-threading.Thread(target=start_bot_thread).start()
+def run_bot():
+    bot.run(DISCORD_TOKEN)
+threading.Thread(target=run_bot).start()
 def greet(name):
     return "Hello " + name + "!"
 demo = gr.Interface(fn=greet, inputs="text", outputs="text")