Merge branch 'master' into fix-bigquery-test_result_rows_scan

Author: michael-myaskovsky

.github/workflows/stale.yml

@@ -11,9 +11,10 @@ jobs:
       issues: write
       pull-requests: write
     steps:
-      - uses: actions/stale@v5
+      - uses: actions/stale@v10
         with:
-          days-before-stale: 180
+          days-before-stale: 60
+          days-before-close: 30
           stale-issue-message: |
             This issue is stale because it has been open for too long with no activity.
             If you would like the issue to remain open, please remove the stale label or leave a comment.

elementary/messages/messaging_integrations/slack_web.py

@@ -41,18 +41,24 @@ class SlackWebMessageContext(BaseModel):
 class SlackWebMessagingIntegration(
     BaseMessagingIntegration[Channel, SlackWebMessageContext]
 ):
-    def __init__(self, client: WebClient, tracking: Optional[Tracking] = None) -> None:
+    def __init__(
+        self,
+        client: WebClient,
+        tracking: Optional[Tracking] = None,
+        reply_broadcast: bool = False,
+    ) -> None:
         self.client = client
         self.tracking = tracking
         self._email_to_user_id_cache: Dict[str, str] = {}
+        self.reply_broadcast = reply_broadcast
 
     @classmethod
     def from_token(
-        cls, token: str, tracking: Optional[Tracking] = None
+        cls, token: str, tracking: Optional[Tracking] = None, **kwargs: Any
     ) -> "SlackWebMessagingIntegration":
         client = WebClient(token=token)
         client.retry_handlers.append(RateLimitErrorRetryHandler(max_retry_count=5))
-        return cls(client, tracking)
+        return cls(client, tracking, **kwargs)
 
     def parse_message_context(self, context: dict[str, Any]) -> SlackWebMessageContext:
         return SlackWebMessageContext(**context)
@@ -77,7 +83,10 @@ def reply_to_message(
     ) -> MessageSendResult[SlackWebMessageContext]:
         formatted_message = format_block_kit(body, self.get_user_id_from_email)
         return self._send_message(
-            destination, formatted_message, thread_ts=message_context.id
+            destination,
+            formatted_message,
+            thread_ts=message_context.id,
+            reply_broadcast=self.reply_broadcast,
         )
 
     @sleep_and_retry
@@ -87,13 +96,15 @@ def _send_message(
         destination: Channel,
         formatted_message: FormattedBlockKitMessage,
         thread_ts: Optional[str] = None,
+        reply_broadcast: bool = False,
     ) -> MessageSendResult[SlackWebMessageContext]:
         try:
             response = self.client.chat_postMessage(
                 channel=destination,
                 blocks=json.dumps(formatted_message.blocks),
                 attachments=json.dumps(formatted_message.attachments),
                 thread_ts=thread_ts,
+                reply_broadcast=reply_broadcast,
             )
         except SlackApiError as e:
             self._handle_send_err(e, destination)