Give follow-up agent timestamps + silence-aware bump/escalate rule so it stops looping on wait

Author: eracle

linkedin/agents/follow_up.py

@@ -7,6 +7,7 @@
 from __future__ import annotations
 
 import logging
+from datetime import datetime, timedelta
 from typing import Literal
 
 import jinja2
@@ -55,19 +56,50 @@ def _check_required_fields(self):
 RECENT_MESSAGES_WINDOW = 6
 
 
-def _format_recent_messages(messages: list) -> str:
-    """Render the last few ChatMessage rows as a `Me:`/`Lead:` transcript."""
+def _humanize_age(when: datetime, now: datetime) -> str:
+    """Render `when` as a coarse age relative to `now` (e.g. ``3d ago``)."""
+    delta = now - when
+    if delta < timedelta(hours=1):
+        return f"{max(int(delta.total_seconds() // 60), 1)}m ago"
+    if delta < timedelta(days=1):
+        return f"{int(delta.total_seconds() // 3600)}h ago"
+    return f"{delta.days}d ago"
+
+
+def _format_recent_messages(messages: list, now: datetime) -> str:
+    """Render the last few ChatMessage rows as a timestamped transcript."""
     if not messages:
         return "No recent messages."
     lines = []
     for m in messages:
-        speaker = "Me" if m.is_outgoing else "Lead"
         content = (m.content or "").strip()
-        if content:
-            lines.append(f"{speaker}: {content}")
+        if not content:
+            continue
+        speaker = "Me" if m.is_outgoing else "Lead"
+        prefix = f"{speaker} ({_humanize_age(m.creation_date, now)})" if m.creation_date else speaker
+        lines.append(f"{prefix}: {content}")
     return "\n".join(lines) or "No recent messages."
 
 
+def _days_since_last_outgoing(messages: list, now: datetime) -> int | None:
+    """Whole days since the most recent outgoing message, or None if there are none."""
+    timestamps = [m.creation_date for m in messages if m.is_outgoing and m.creation_date]
+    if not timestamps:
+        return None
+    return max((now - max(timestamps)).days, 0)
+
+
+def _count_unanswered_outgoing(messages: list) -> int:
+    """Trailing run of outgoing messages with no lead reply after them."""
+    count = 0
+    for m in reversed(messages):
+        if m.is_outgoing:
+            count += 1
+        else:
+            break
+    return count
+
+
 def _format_facts(summary: dict | None) -> str:
     """Render a `{facts: [...]}` summary blob as a bullet list."""
     facts = (summary or {}).get("facts") or []
@@ -92,21 +124,27 @@ def _load_recent_messages(deal, limit: int = RECENT_MESSAGES_WINDOW) -> list:
 
 def _render_system_prompt(session, deal, recent_messages: list) -> str:
     """Render the agent system prompt from the Jinja2 template."""
+    from django.utils import timezone
+
     env = jinja2.Environment(loader=jinja2.FileSystemLoader(str(PROMPTS_DIR)))
     template = env.get_template("follow_up_agent.j2")
 
     campaign = deal.campaign
     self_prof = session.self_profile
     self_name = f"{self_prof.get('first_name', '')} {self_prof.get('last_name', '')}".strip() or session.django_user.username
 
+    now = timezone.now()
     return template.render(
         self_name=self_name,
         product_docs=campaign.product_docs or "",
         campaign_objective=campaign.campaign_objective or "",
         booking_link=campaign.booking_link or "",
         profile_summary=_format_facts(deal.profile_summary),
         chat_summary=_format_facts(deal.chat_summary),
-        recent_messages=_format_recent_messages(recent_messages),
+        recent_messages=_format_recent_messages(recent_messages, now),
+        today=now.strftime("%Y-%m-%d"),
+        days_since_last_outgoing=_days_since_last_outgoing(recent_messages, now),
+        unanswered_outgoing=_count_unanswered_outgoing(recent_messages),
     )
 
 

linkedin/templates/prompts/follow_up_agent.j2

@@ -21,6 +21,11 @@ You are: {{ self_name }}
 {{ chat_summary }}
 
 ## Most Recent Messages (verbatim)
+Today is {{ today }}. Each line is tagged with how long ago it was sent.
+{% if days_since_last_outgoing is not none -%}
+You last messaged this lead {{ days_since_last_outgoing }} day(s) ago.
+You have sent {{ unanswered_outgoing }} message(s) in a row without a reply.
+{% endif -%}
 {{ recent_messages }}
 
 ## Instructions
@@ -38,5 +43,5 @@ Decide what to do next for this lead. Choose exactly one action:
 - Do NOT sign messages with a name or signature.
 - If there are no recent messages, send a first message introducing yourself and the value proposition, grounded in the profile facts.
 - If there are recent messages, respond contextually to the literal phrasing of the last message — match its tone and language.
-- If they seem uninterested or haven't replied after multiple attempts, mark as completed.
+- Use the timestamps to reason about silence. Rough guide: if your last message was < 5 days ago, prefer **wait**; if it's been 5-14 days with no reply, send a short, low-pressure bump that references the prior message; after 3 unanswered outgoing messages in a row, **mark_completed** as cold.
 - Include the booking link naturally in the message when suggesting a call or meeting, not as a separate line.