feat(funding): add retry policy

app/activities/check_funding_relevance.py

@@ -3,14 +3,24 @@
 
 """LLM-based funding relevance check activity."""
 
+from datetime import timedelta
+
 from pydantic import BaseModel, Field
 from temporalio import activity
+from temporalio.common import RetryPolicy
 
 from app.agent import build_agent
 from app.config import get_settings
 from app.observability import propagate_langfuse_context
 from app.workflows.specs import WorkflowContext
 
+FUNDING_WORKFLOW_RETRY_POLICY = RetryPolicy(
+    initial_interval=timedelta(seconds=5),
+    backoff_coefficient=2,
+    maximum_interval=timedelta(seconds=20),
+    maximum_attempts=3,
+)
+
 
 class CheckFundingRelevanceRequest(BaseModel):
     """Request to check if record metadata matches an award description."""

app/workflows/check_funding_relevance_workflow.py

@@ -6,6 +6,7 @@
 from temporalio import workflow
 
 from app.activities.check_funding_relevance import (
+    FUNDING_WORKFLOW_RETRY_POLICY,
     CheckFundingRelevanceRequest,
     CheckFundingRelevanceResponse,
     check_funding_relevance,
@@ -61,6 +62,7 @@ async def run(
                     context,
                 ],
                 start_to_close_timeout=timedelta(minutes=2),
+                retry_policy=FUNDING_WORKFLOW_RETRY_POLICY,
             )
         except Exception:
             await workflow.execute_activity(