fix(worker): propagate platform metadata to interactive buttons

Author: PyDevDeep

backend/workers/callbacks.py

@@ -43,7 +43,7 @@ async def _send_slack_message(payload: dict[str, Any]) -> None:
 
 
 async def notify_slack_on_complete(
-    user_id: str, channel_id: str, draft: str, topic: str, draft_id: str
+    user_id: str, channel_id: str, draft: str, topic: str, draft_id: str, platform: str
 ) -> None:
     logger.info(
         "sending_slack_completion_notification", user_id=user_id, channel_id=channel_id
@@ -53,7 +53,11 @@ async def notify_slack_on_complete(
         "channel": channel_id,
         "text": SLACK_UI["draft_ready_fallback"].format(topic=topic),
         "blocks": build_draft_card(
-            topic=topic, draft=draft, user_id=user_id, draft_id=draft_id
+            topic=topic,
+            draft=draft,
+            user_id=user_id,
+            draft_id=draft_id,
+            platform=platform,
         ),
     }
     await _send_slack_message(payload)

backend/workers/tasks/generate_draft.py

@@ -4,13 +4,15 @@
 from taskiq import TaskiqDepends
 
 from backend.services.content_generator import ContentGenerator, JudgeFailedError
+from backend.workers.broker import broker
 from backend.workers.callbacks import notify_slack_on_complete, notify_slack_on_failure
 from backend.workers.dependencies import get_content_generator
 
 logger = structlog.get_logger()
 
 
 # Збільшено timeout до 180 секунд через наявність циклу LLM-as-a-Judge та Retries
+@broker.task(task_name="generate_medical_draft", timeout=180)
 async def generate_draft_task(
     topic: str,
     platform: str,
@@ -49,6 +51,7 @@ async def generate_draft_task(
                 draft=result,
                 topic=topic,
                 draft_id=draft_id,
+                platform=platform,
             )
 
         return result

slack_app/utils/block_builder.py

@@ -4,7 +4,7 @@
 
 
 def build_draft_card(
-    topic: str, draft: str, user_id: str, draft_id: str
+    topic: str, draft: str, user_id: str, draft_id: str, platform: str
 ) -> list[dict[str, Any]]:
     """Генерує картку чернетки з кнопками дій."""
     return [
@@ -41,7 +41,7 @@ def build_draft_card(
                         "emoji": True,
                     },
                     "style": "primary",
-                    "value": draft_id,
+                    "value": f"{draft_id}|{platform}",  # ПРОШИВАЄМО ID ТА ПЛАТФОРМУ
                     "action_id": "action_publish_draft",
                 },
                 {
@@ -51,7 +51,7 @@ def build_draft_card(
                         "text": SLACK_UI["btn_edit"],
                         "emoji": True,
                     },
-                    "value": draft_id,
+                    "value": f"{draft_id}|{platform}",
                     "action_id": "action_edit_draft",
                 },
                 {
@@ -61,7 +61,7 @@ def build_draft_card(
                         "text": SLACK_UI["btn_regenerate"],
                         "emoji": True,
                     },
-                    "value": "regenerate",
+                    "value": f"{draft_id}|{platform}",
                     "action_id": "action_regenerate_draft",
                 },
                 {
@@ -72,7 +72,7 @@ def build_draft_card(
                         "emoji": True,
                     },
                     "style": "danger",
-                    "value": "reject",
+                    "value": f"{draft_id}|{platform}",
                     "action_id": "action_reject_draft",
                 },
             ],