Fix duplicate bot responses, add S3 rclone flags, and increase transfer job resources

Fix triage model ID (claude-haiku-4-20250414 → claude-haiku-4-5-20251001) that
was causing 404 errors and fail-open duplicate responses. Deduplicate @mention
messages in the thread handler since handle_mention already processes them.
Append S3-specific upload flags when destination is an S3 endpoint. Increase
transfer job defaults to 4-day wall clock, 16 CPUs, and 100G memory.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: fluidnumerics-joe

src/xfer/slackbot/app.py

@@ -197,7 +197,7 @@ def handle_mention(event: dict[str, Any], say: Any) -> None:
             )
 
     @app.event("message")
-    def handle_message(event: dict[str, Any], say: Any) -> None:
+    def handle_message(event: dict[str, Any], say: Any, context: dict[str, Any]) -> None:
         """
         Handle direct messages and thread replies.
 
@@ -254,6 +254,11 @@ def handle_message(event: dict[str, Any], say: Any) -> None:
             if not is_allowed_channel(channel):
                 return
 
+            # Skip @mentions — handle_mention already processes those
+            bot_user_id = context.get("bot_user_id", "")
+            if bot_user_id and f"<@{bot_user_id}>" in text:
+                return
+
             # Check if we have history in this thread (meaning we've been mentioned)
             history = conversations.get(channel, thread_ts)
 

src/xfer/slackbot/config.py

@@ -15,9 +15,9 @@ class SlurmDefaults:
     """Default Slurm job parameters."""
 
     partition: str = "transfer"
-    time_limit: str = "24:00:00"
-    cpus_per_task: int = 4
-    mem: str = "8G"
+    time_limit: str = "4-00:00:00"
+    cpus_per_task: int = 16
+    mem: str = "100G"
     array_concurrency: int = 64
     num_shards: int = 256
     max_attempts: int = 5
@@ -60,7 +60,7 @@ class BotConfig:
         default_factory=lambda: os.environ.get("ANTHROPIC_API_KEY", "")
     )
     claude_model: str = "claude-sonnet-4-20250514"
-    triage_model: str = "claude-haiku-4-20250414"
+    triage_model: str = "claude-haiku-4-5-20251001"
 
     # Paths
     runs_base_dir: Path = field(default_factory=lambda: Path.home() / "xfer-runs")

src/xfer/slackbot/slurm_tools.py

@@ -195,6 +195,9 @@ def _write_prepare_script(
     # User flags to append after analysis-suggested flags
     user_rclone_flags = rclone_flags or ""
 
+    # Extract remote name from dest for S3 detection
+    dest_remote = dest.split(":")[0]
+
     # Get xfer install directory for uv
     xfer_dir = config.xfer_install_dir or Path(__file__).parent.parent.parent.parent.resolve()
 
@@ -363,6 +366,24 @@ def _write_prepare_script(
 else
     RCLONE_FLAGS="$SUGGESTED_FLAGS"
 fi
+
+# Append S3-specific flags when destination is an S3 endpoint
+DEST_TYPE=$(python3 -c "
+import configparser
+remote = '{dest_remote}'
+if remote == 's3':
+    print('s3')
+else:
+    c = configparser.ConfigParser()
+    c.read('{config.rclone.config_path}')
+    print(c.get(remote, 'type', fallback=''))
+")
+if [ "$DEST_TYPE" = "s3" ]; then
+    S3_FLAGS="--s3-upload-concurrency 8 --buffer-size=32M --multi-thread-stream=8 --multi-thread-cutoff=64M --s3-upload-cutoff 0 --s3-chunk-size 32M"
+    RCLONE_FLAGS="$RCLONE_FLAGS $S3_FLAGS"
+    echo "S3 destination detected, appended: $S3_FLAGS"
+fi
+
 echo "Final rclone flags: $RCLONE_FLAGS"
 
 echo "=== Analysis complete at $(date -Is) ==="