Update app.py

app.py

@@ -8,7 +8,8 @@ from slack_sdk.errors import SlackApiError
 import aiojobs
 import asyncio
 from datetime import datetime, timedelta
-from apscheduler.schedulers.asyncio import AsyncIOScheduler
+from apscheduler.executors.pool import ThreadPoolExecutor
+from apscheduler.schedulers.background import BackgroundScheduler
 
 
 DISCORD_TOKEN = os.getenv('DISCORD_TOKEN')
@@ -147,13 +148,21 @@ def post_to_slack_create_thread(channel, text, thread_ts=None):
 
 #----------------------------------------------------------------------------------------------
 
-async def send_daily_pings():
+def send_daily_pings():
     global daily_pings
     if daily_pings:
         print("sending daily pings...")
         # combine into one message
         combined_message = '\n'.join(f"{ping['author']} in #{ping['channel']} said: {ping['content']} (link: {ping['url']})" for ping in daily_pings)
-        await post_to_slack(None, combined_message, SLACK_CHANNEL_ID_TEST, None, None, None)
+        #await post_to_slack(None, combined_message, SLACK_CHANNEL_ID_TEST, None, None, None)
+
+        
+        response = slack_client.chat_postMessage(
+            channel=SLACK_CHANNEL_ID_TEST,
+            text=combined_message
+        )        
+
+        
         daily_pings = []  # reset after posting
 
 # pings -------------------------------------------------------------------------------------------
@@ -168,8 +177,9 @@ 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)
+executor = ThreadPoolExecutor(max_workers=1)
+scheduler = BackgroundScheduler(executors={'default': executor})
+scheduler.add_job(send_daily_pings, trigger='interval', seconds=10)
 scheduler.start()