test separate thread daily pings

app.py

@@ -28,40 +28,15 @@ ARGILLA_HELP_CHANNEL_ID = 1253640751481356330
 DATA_DISCUSSIONS_CHANNEL_ID = 1217179426002047076
 
 
+# U051DB2754M == adam hf real slack
+# U061W3NRFFA == lunarflu test slack
+
 TRIGGERS = {
     ("discord bot",): "<@U051DB2754M>", # adam
-    ("autotrain",): "<@U01E3LEC2N7>", # abhishek
-    ("auto train",): "<@U01E3LEC2N7>", # abhishek
-    ("competition",): "<@U01E3LEC2N7>", # abhishek
-    ("competitions",): "<@U01E3LEC2N7>", # abhishek
-    ("text to speech",): "<@U039C2GANMV>", # VB
-    ("tts",): "<@U039C2GANMV>", # VB
-    ("asr",): "<@U039C2GANMV>", # VB
-    ("musicgen",): "<@U039C2GANMV>", # VB
-    ("whisper",): "<@U039C2GANMV>", # VB
-    ("speech recognition",): "<@U039C2GANMV>", # VB
-    ("bark",): "<@U039C2GANMV>", # VB
-    ("sentence-transformers",): "<@U04E4DNPWG7>", # tom aarsen
-    ("sentence_transformers",): "<@U04E4DNPWG7>", # tom aarsen
-    ("setfit",): "<@U04E4DNPWG7>", # tom aarsen
-    ("sentence transformers",): "<@U04E4DNPWG7>", # tom aarsen
-    ("argilla",): "<@U076B8C7G3E>", # david berenstein
-    ("distilabel",): "<@U076B8C7G3E>", # david berenstein
-    ("argilla",): "<@U0766H30T7F>", # natalia elvira
-    ("dataset",): "<@U0766H30T7F>", # natalia elvira
-    ("docs",): "<@U02DATT4C5B>", # steven liu
-    ("documentation",): "<@U02DATT4C5B>", # steven liu
-    ("gradio",): "<@U02NMK75F1V>", # abubakar abid
-    ("gradio",): "<@U04FLGQ26PQ>", # yuvraj sharma
-    ("argilla",): "<@U076MF65WEM>", # sara han diaz lorenzo
-    ("distilabel",): "<@U076MF65WEM>", # sara han diaz lorenzo
-    ("argilla",): "<@U0765RENPNZ>", # sara han diaz lorenzo
-    ("distilabel",): "<@U0765RENPNZ>", # sara han diaz lorenzo
-    ("dataset", "feedback"): "<@U0768RCHCRY>", # ben burtenshaw
-    ("distilabel",): "<@U0768QEN0LA>", # Gabriel Martín Blázquez
-    ("distilabel",): "<@U076271MBUN>", # Agustín Piqueres    
+	("lunarflu",): "<@U061W3NRFFA>" # lunarflu test slack
 }
 
+
 daily_pings = []
 
 intents = discord.Intents.all()
@@ -241,29 +216,39 @@ def send_daily_pings():
     global daily_pings
     if daily_pings:
         print(f"sending daily pings...{daily_pings}")
-        # combine into one message
-        main_message = slack_client.chat_postMessage(
-            channel=SLACK_CHANNEL_ID,
-            text=f"DAILY PINGS FOR {datetime.now().strftime('%d/%m/%Y')}",
-            unfurl_links=False,
-            unfurl_media=False
-        )
-        main_ts = main_message['ts']
+        pings_by_mention = {}
+        
+        # group pings by mention
         for ping in daily_pings:
-            slack_client.chat_postMessage(
-                channel=SLACK_CHANNEL_ID,
-                text=f"{ping['mention']} (for the keyword -> '{ping['trigger']}')\nFrom {ping['author']} in channel #{ping['channel']}: {ping['content']}\n{ping['url']}",
-                thread_ts=main_ts,
+            mention = ping['mention']
+            if mention not in pings_by_mention:
+                pings_by_mention[mention] = []
+            pings_by_mention[mention].append(ping)
+        
+        # send each group of pings in a separate thread
+        for mention, pings in pings_by_mention.items():
+            main_message = slack_client.chat_postMessage(
+                channel=TEST_SLACK_CHANNEL_ID_TEST,
+                text=f"DAILY PINGS FOR {mention} ON {datetime.now().strftime('%d/%m/%Y')}",
                 unfurl_links=False,
                 unfurl_media=False
-            )   
+            )
+            main_ts = main_message['ts']
+            for ping in pings:
+                slack_client.chat_postMessage(
+                    channel=TEST_SLACK_CHANNEL_ID_TEST,
+                    text=f"{ping['mention']} (for the keyword -> '{ping['trigger']}')\nFrom {ping['author']} in channel #{ping['channel']}: {ping['content']}\n{ping['url']}",
+                    thread_ts=main_ts,
+                    unfurl_links=False,
+                    unfurl_media=False
+                )   
 
         daily_pings = []  # reset after posting
 
 # pings -------------------------------------------------------------------------------------------
 executor = ThreadPoolExecutor(max_workers=1)
 scheduler = BackgroundScheduler(executors={'default': executor})
-scheduler.add_job(send_daily_pings, trigger='interval', days=1)
+scheduler.add_job(send_daily_pings, trigger='interval', seconds=30)
 scheduler.start()