One-step slack format

Author: Peter-Sh

src/redis_release/bht/tree.py

@@ -142,6 +142,7 @@ def initialize_tree_and_state(
                     args.slack_channel_id,
                     args.slack_thread_ts,
                     args.slack_reply_broadcast,
+                    args.slack_format,
                 )
                 # Capture the non-None printer in the closure
                 printer = slack_printer

src/redis_release/cli.py

@@ -271,6 +271,11 @@ def slack_bot(
         "--authorized-user",
         help="User ID authorized to run releases (can be specified multiple times). If not specified, all users are authorized",
     ),
+    slack_format: str = typer.Option(
+        "default",
+        "--slack-format",
+        help="Slack message format: 'default' shows all steps, 'one-step' shows only the last step",
+    ),
 ) -> None:
     """Run Slack bot that listens for status requests.
 
@@ -285,20 +290,33 @@ def slack_bot(
 
     Requires Socket Mode to be enabled in your Slack app configuration.
     """
+    from redis_release.models import SlackFormat
     from redis_release.slack_bot import run_bot
 
     setup_logging()
     config_path = config_file or "config.yaml"
 
+    # Parse slack_format
+    try:
+        slack_format_enum = SlackFormat(slack_format)
+    except ValueError:
+        logger.error(
+            f"Invalid slack format: {slack_format}. Must be 'default' or 'one-step'"
+        )
+        raise typer.BadParameter(
+            f"Invalid slack format: {slack_format}. Must be 'default' or 'one-step'"
+        )
+
     logger.info("Starting Slack bot...")
     asyncio.run(
         run_bot(
-            config_path,
-            slack_bot_token,
-            slack_app_token,
-            reply_in_thread,
-            broadcast_to_channel,
-            authorized_users,
+            config_path=config_path,
+            slack_bot_token=slack_bot_token,
+            slack_app_token=slack_app_token,
+            reply_in_thread=reply_in_thread,
+            broadcast_to_channel=broadcast_to_channel,
+            authorized_users=authorized_users,
+            slack_format=slack_format_enum,
         )
     )
 

src/redis_release/models.py

@@ -60,6 +60,13 @@ class ReleaseType(str, Enum):
     INTERNAL = "internal"
 
 
+class SlackFormat(str, Enum):
+    """Slack message format enumeration."""
+
+    DEFAULT = "default"
+    ONE_STEP = "one-step"
+
+
 class WorkflowStatus(str, Enum):
     """Workflow status enumeration."""
 
@@ -241,3 +248,4 @@ class ReleaseArgs(BaseModel):
     slack_channel_id: Optional[str] = None
     slack_thread_ts: Optional[str] = None
     slack_reply_broadcast: bool = False
+    slack_format: SlackFormat = SlackFormat.DEFAULT

src/redis_release/slack_bot.py

@@ -13,7 +13,7 @@
 
 from redis_release.bht.tree import async_tick_tock, initialize_tree_and_state
 from redis_release.config import Config, load_config
-from redis_release.models import ReleaseArgs
+from redis_release.models import ReleaseArgs, SlackFormat
 from redis_release.state_manager import S3StateStorage, StateManager
 from redis_release.state_slack import init_slack_printer
 
@@ -34,6 +34,7 @@ def __init__(
         reply_in_thread: bool = True,
         broadcast_to_channel: bool = False,
         authorized_users: Optional[List[str]] = None,
+        slack_format: SlackFormat = SlackFormat.DEFAULT,
     ):
         """Initialize the bot.
 
@@ -44,11 +45,13 @@ def __init__(
             reply_in_thread: If True, reply in thread. If False, reply in main channel
             broadcast_to_channel: If True and reply_in_thread is True, also show in main channel
             authorized_users: List of user IDs authorized to run releases. If None, all users are authorized
+            slack_format: Slack message format (default or one-step)
         """
         self.config = config
         self.reply_in_thread = reply_in_thread
         self.broadcast_to_channel = broadcast_to_channel
         self.authorized_users = authorized_users or []
+        self.slack_format = slack_format
 
         # Get tokens from args or environment
         bot_token = slack_bot_token or os.environ.get("SLACK_BOT_TOKEN")
@@ -261,6 +264,7 @@ def run_release_in_thread() -> None:
                     slack_channel_id=channel,
                     slack_thread_ts=thread_ts if self.reply_in_thread else None,
                     slack_reply_broadcast=reply_broadcast,
+                    slack_format=self.slack_format,
                 )
 
                 # Run the release
@@ -355,6 +359,7 @@ async def _post_status(
                     slack_channel_id=channel,
                     thread_ts=thread_ts if self.reply_in_thread else None,
                     reply_broadcast=self.broadcast_to_channel,
+                    slack_format=self.slack_format,
                 )
                 printer.update_message(state)
 
@@ -391,6 +396,7 @@ async def run_bot(
     reply_in_thread: bool = True,
     broadcast_to_channel: bool = False,
     authorized_users: Optional[List[str]] = None,
+    slack_format: SlackFormat = SlackFormat.DEFAULT,
 ) -> None:
     """Run the Slack bot.
 
@@ -401,6 +407,7 @@ async def run_bot(
         reply_in_thread: If True, reply in thread. If False, reply in main channel
         broadcast_to_channel: If True and reply_in_thread is True, also show in main channel
         authorized_users: List of user IDs authorized to run releases. If None, all users are authorized
+        slack_format: Slack message format (default or one-step)
     """
     # Load config
     config = load_config(config_path)
@@ -413,6 +420,7 @@ async def run_bot(
         reply_in_thread=reply_in_thread,
         broadcast_to_channel=broadcast_to_channel,
         authorized_users=authorized_users,
+        slack_format=slack_format,
     )
 
     await bot.start()

src/redis_release/state_slack.py

@@ -9,6 +9,7 @@
 from slack_sdk import WebClient
 from slack_sdk.errors import SlackApiError
 
+from redis_release.models import SlackFormat
 from redis_release.state_display import DisplayModel, StepStatus
 
 from .bht.state import (
@@ -44,6 +45,7 @@ def init_slack_printer(
     slack_channel_id: Optional[str],
     thread_ts: Optional[str] = None,
     reply_broadcast: bool = False,
+    slack_format: SlackFormat = SlackFormat.DEFAULT,
 ) -> "SlackStatePrinter":
     """Initialize SlackStatePrinter with validation.
 
@@ -52,6 +54,7 @@ def init_slack_printer(
         slack_channel_id: Slack channel ID to post to
         thread_ts: Optional thread timestamp to post messages in a thread
         reply_broadcast: If True and thread_ts is set, also show in main channel
+        slack_format: Slack message format (default or one-step)
 
     Returns:
         SlackStatePrinter instance
@@ -69,7 +72,9 @@ def init_slack_printer(
             "Slack token not provided. Use slack_token argument or set SLACK_BOT_TOKEN environment variable"
         )
 
-    return SlackStatePrinter(token, slack_channel_id, thread_ts, reply_broadcast)
+    return SlackStatePrinter(
+        token, slack_channel_id, thread_ts, reply_broadcast, slack_format
+    )
 
 
 class SlackStatePrinter:
@@ -81,6 +86,7 @@ def __init__(
         slack_channel_id: str,
         thread_ts: Optional[str] = None,
         reply_broadcast: bool = False,
+        slack_format: SlackFormat = SlackFormat.DEFAULT,
     ):
         """Initialize the Slack printer.
 
@@ -89,11 +95,13 @@ def __init__(
             slack_channel_id: Slack channel ID to post messages to
             thread_ts: Optional thread timestamp to post messages in a thread
             reply_broadcast: If True and thread_ts is set, also show in main channel
+            slack_format: Slack message format (default or one-step)
         """
         self.client = WebClient(token=slack_token)
         self.channel_id: str = slack_channel_id
         self.thread_ts = thread_ts
         self.reply_broadcast = reply_broadcast
+        self.slack_format = slack_format
         self.message_ts: Optional[str] = None
         self.last_blocks_json: Optional[str] = None
         self.started_at = datetime.now(timezone.utc)
@@ -409,16 +417,31 @@ def _format_steps_for_slack(
         details: List[str] = []
         details.append(f"*{prefix}*")
 
-        for step_status, step_name, step_message in steps:
-            if step_status == StepStatus.SUCCEEDED:
-                details.append(f"• ✅ {step_name}")
-            elif step_status == StepStatus.RUNNING:
-                details.append(f"• ⏳ {step_name}")
-            elif step_status == StepStatus.NOT_STARTED:
-                details.append(f"• ⚪ {step_name}")
-            else:  # FAILED or INCORRECT
-                msg = f" ({step_message})" if step_message else ""
-                details.append(f"• ❌ {step_name}{msg}")
-                break
+        # If one-step format, only show the last step
+        if self.slack_format == SlackFormat.ONE_STEP:
+            if steps:
+                step_status, step_name, step_message = steps[-1]
+                if step_status == StepStatus.SUCCEEDED:
+                    details.append(f"• ✅ {step_name}")
+                elif step_status == StepStatus.RUNNING:
+                    details.append(f"• ⏳ {step_name}")
+                elif step_status == StepStatus.NOT_STARTED:
+                    details.append(f"• ⚪ {step_name}")
+                else:  # FAILED or INCORRECT
+                    msg = f" ({step_message})" if step_message else ""
+                    details.append(f"• ❌ {step_name}{msg}")
+        else:
+            # Default format: show all steps
+            for step_status, step_name, step_message in steps:
+                if step_status == StepStatus.SUCCEEDED:
+                    details.append(f"• ✅ {step_name}")
+                elif step_status == StepStatus.RUNNING:
+                    details.append(f"• ⏳ {step_name}")
+                elif step_status == StepStatus.NOT_STARTED:
+                    details.append(f"• ⚪ {step_name}")
+                else:  # FAILED or INCORRECT
+                    msg = f" ({step_message})" if step_message else ""
+                    details.append(f"• ❌ {step_name}{msg}")
+                    break
 
         return details