Automatically convert incoming emails into prioritized Linear issues using AI-powered triage. Extract customer information, priority levels, and issue types from raw email content, then instantly create structured tickets in your Linear workspace with Slack notifications for urgent items.
This template provides a production-ready FastAPI webhook service that:
- Accepts emails via SMTP forwarding or Gmail API integration
- Extracts priority, customer, and issue classification using Claude AI
- Creates Linear issues with rich metadata and proper linking
- Sends Slack alerts for high-priority tickets
- Stores triage decisions for audit and refinement
Why use this?
Cost savings: Eliminates $20-40/mo Zapier fees + manual triage overheadSpeed: 30-second email-to-ticket pipeline vs. 5-minute manual routingConsistency: AI-driven classification reduces human error in priority assignmentExtensibility: Built on Pydantic AI for easy customization of triage logic
- Accepts raw email POST payloads (SMTP webhook format or parsed JSON)
- Extracts sender, subject, body, and attachment metadata
- Supports both plain text and HTML email bodies
Uses Claude to extract from email content:
Priority level(urgent/high/normal/low)** Customer identifier**(email domain, name, account ID)** Issue type**(bug/feature-request/support/billing)** Summary**(auto-generated from subject + body context)** Suggested assignee**(based on issue type patterns, optional)
-
Creates issues in your Linear workspace
-
Attaches original email as issue comment
-
Sets priority and status based on triage output
-
Links to customer/team projects (configurable)
-
Supports custom fields for email metadata
-
Posts urgent/high-priority tickets to designated channel
-
Includes customer info, issue link, and priority badge
-
Optional thread replies for follow-up updates
-
Stores all triage decisions in SQLite (or configured DB)
-
Enables performance monitoring and model refinement
-
Supports manual override and feedback loops
Python 3.11+Linear API token(create inSettings > API > Personal API Keys) Claude API key(fromAnthropic Console)** Slack webhook URL**(optional, fromSlack Apps)** Gmail API credentials**or SMTP relay service (optional, for email ingestion)
- Docker + Docker Compose (for containerized deployment)
- PostgreSQL (for production database, defaults to SQLite)
git clone https://github.com/yourusername/email-linear-triage.git
cd email-linear-triage
python -m venv venv
source venv/bin/activate # On Windows: venv\Scripts\activate
pip install -r requirements.txt
Create .env
in the project root:
ANTHROPIC_API_KEY=sk-ant-...
LINEAR_API_KEY=lin_api_...
SLACK_WEBHOOK_URL=https://hooks.slack.com/services/YOUR/WEBHOOK/URL # Optional
LINEAR_TEAM_ID=acme # Your Linear team slug (e.g., 'acme' from linear.app/acme)
LINEAR_PROJECT_ID=INB # Project key for incoming emails (default: 'INB')
LINEAR_DEFAULT_STATUS=backlog # Initial status for new issues
SMTP_SECRET_TOKEN=your-secret-token-here # For webhook authentication
EMAIL_DOMAIN=yourdomain.com
DATABASE_URL=sqlite:///./triage.db # Or: postgresql://user:pass@localhost/triage
ENABLE_SLACK_NOTIFICATIONS=true
ENABLE_AUTO_ASSIGN=false
TRIAGE_MODEL=claude-3-5-sonnet-20241022 # Claude model to use
python -m alembic upgrade head
Or for SQLite (auto-created):
python -c "from app.db import init_db; init_db()"
uvicorn app.main:app --host 0.0.0.0 --port 8000 --reload
Server runs on http://localhost:8000
Option A: SMTP Forwarding (Recommended)
- In your email provider, set up a forward rule:
From:
tickets@yourdomain.com
To:{your-server}/webhook/email
with authentication
Option B: Gmail API
-
Enable Gmail APIin Google Cloud Console - Download credentials JSON to
./credentials.json -
App auto-fetches labeled emails periodically
Option C: Manual Testing
curl -X POST http://localhost:8000/webhook/email \
-H "X-Webhook-Token: your-secret-token-here" \
-H "Content-Type: application/json" \
-d '{
"from": "customer@example.com",
"subject": "Payment processing is broken",
"body": "Hi, our recurring invoices havent charged for 2 days. This is urgent!",
"timestamp": "2024-01-15T14:30:00Z"
}'
In Linear Settings > Integrations > Webhooks, add:
URL:{your-server}/webhook/linear-event
Events: Issue created, issue updated- Useful for closing issues via email replies
Email arrives attickets@yourdomain.com
(forwarded via SMTP)Webhook handler receives POST, validates tokenClaude triage classifies email (2-5 seconds)Linear issue created with extracted metadataSlack notification posted (if urgent/high)Response returned with issue URL
curl -X POST http://localhost:8000/webhook/email \
-H "X-Webhook-Token: your-secret-token-here" \
-H "Content-Type: application/json" \
-d '{
"from": "sarah@acmecorp.com",
"subject": "[BUG] Dashboard crashes on mobile",
"body": "When I open the dashboard on iPhone, it instantly crashes. Happens every time. Our team cant work.",
"timestamp": "2024-01-15T09:30:00Z"
}'
Response (201 Created):
{
"status": "success",
"linear_issue_id": "INB-234",
"linear_issue_url": "https://linear.app/acme/issue/INB-234",
"triage_result": {
"priority": "urgent",
"issue_type": "bug",
"customer_domain": "acmecorp.com",
"summary": "Dashboard mobile app crashes on iOS",
"suggested_assignee": "eng-mobile"
},
"slack_notification_sent": true,
"processing_time_ms": 3200
}
Ingest raw email and create Linear issue
Headers:
X-Webhook-Token: {SMTP_SECRET_TOKEN}
Content-Type: application/json
Request Body:
{
"from": "customer@example.com",
"subject": "Issue title",
"body": "Email body text",
"html_body": "<p>HTML version (optional)</p>",
"timestamp": "2024-01-15T10:00:00Z",
"attachments": [
{
"filename": "screenshot.png",
"content_base64": "iVBORw0KGgoAAAANS...",
"mime_type": "image/png"
}
]
}
Response (201 Created):
{
"status": "success|error",
"linear_issue_id": "INB-123",
"linear_issue_url": "string",
"triage_result": {
"priority": "urgent|high|normal|low",
"issue_type": "bug|feature|support|billing",
"customer_domain": "string",
"customer_name": "string (optional)",
"summary": "string",
"suggested_assignee": "string (optional)"
},
"slack_notification_sent": boolean,
"error": "string (if status='error')"
}
Manually override AI triage decision
Headers:
X-API-Key: {LINEAR_API_KEY}
Content-Type: application/json
Request Body:
{
"priority": "high",
"issue_type": "bug",
"notes": "Manually corrected from 'low' due to context"
}
Response (200 OK):
{
"status": "updated",
"triage_record_id": "uuid",
"changes": {
"priority": {"old": "normal", "new": "high"}
}
}
Retrieve triage history and metrics
Query Parameters:
limit=50
(default)offset=0
priority_filter=urgent|high|normal|low
(optional)date_from=2024-01-01
(optional)date_to=2024-01-31
(optional)
Response (200 OK):
{
"total_processed": 342,
"results": [
{
"id": "uuid",
"email_from": "customer@example.com",
"linear_issue_id": "INB-234",
"priority": "high",
"issue_type": "bug",
"created_at": "2024-01-15T09:30:00Z",
"processing_time_ms": 3200,
"model_confidence": 0.94
}
],
"statistics": {
"avg_processing_time_ms": 2800,
"priority_distribution": {
"urgent": 15,
"high": 87,
"normal": 198,
"low": 42
},
"issue_type_distribution": {
"bug": 124,
"feature": 56,
"support": 142,
"billing": 20
}
}
}
Service health check
Response (200 OK):
{
"status": "healthy",
"timestamp": "2024-01-15T10:00:00Z",
"dependencies": {
"anthropic": "ok",
"linear": "ok",
"slack": "ok",
"database": "ok"
}
}
| Variable | Required | Default | Description |
|---|---|---|---|
ANTHROPIC_API_KEY |
|||
| β | β | Claude API key from Anthropic Console | |
LINEAR_API_KEY |
|||
| β | β | Linear API token from Settings > API | |
LINEAR_TEAM_ID |
|||
| β | β | Linear team slug (e.g., 'acme') | |
LINEAR_PROJECT_ID |
|||
INB |
|||
| Linear project key for new issues | |||
LINEAR_DEFAULT_STATUS |
|||
backlog |
|||
| Initial issue status (backlog/todo/in_progress) | |||
SMTP_SECRET_TOKEN |
|||
| β | β | Secret token for webhook authentication | |
SLACK_WEBHOOK_URL |
|||
| β | Slack webhook URL (leave empty to disable) | ||
ENABLE_SLACK_NOTIFICATIONS |
|||
true |
|||
| Post notifications for urgent/high | |||
ENABLE_AUTO_ASSIGN |
|||
false |
|||
| Automatically assign based on issue type | |||
TRIAGE_MODEL |
|||
claude-3-5-sonnet-20241022 |
|||
| Claude model (3-opus-20250219 for best accuracy) | |||
DATABASE_URL |
|||
sqlite:///./triage.db |
|||
| PostgreSQL or SQLite connection string | |||
GMAIL_CREDENTIALS_PATH |
|||
./credentials.json |
|||
| Path to Gmail API credentials (if using Gmail) | |||
EMAIL_DOMAIN |
|||
| β | Your email domain (for reply-to headers) | ||
LOG_LEVEL |
|||
INFO |
|||
| Logging level (DEBUG/INFO/WARNING/ERROR) |
Edit app/config.py
to customize:
TRIAGE_MODEL = "claude-3-5-sonnet-20241022" # Change to claude-3-opus-20250219 for higher accuracy
PRIORITY_KEYWORDS = {
"urgent": ["critical", "down", "broken", "asap", "emergency"],
"high": ["bug", "broken", "failing", "urgent"],
"normal": ["feature", "improve"],
"low": ["typo", "minor", "nice-to-have"]
}
LINEAR_PRIORITY_MAP = {
"urgent": 4, # Urgent in Linear
"high": 3,
"normal": 2,
"low": 1
}
Edit app/agents/triage_agent.py
:
TRIAGE_SYSTEM_PROMPT = """You are an expert customer support triage system...
Analyze the email and extract:
1. Priority (urgent/high/normal/low) - consider customer tone, service impact, frequency
2. Issue type (bug/feature/support/billing) - classify by nature
3. Customer identifier - extract domain or company name
4. Concise summary - max 10 words
5. Suggested team - based on issue type
"""
In app/models/triage.py
, extend TriageResult
:
class TriageResult(BaseModel):
priority: str
issue_type: str
customer_domain: str
summary: str
custom_field_1: str | None = None # Add your field
Then update the Claude prompt to extract it, and Linear creation logic in app/integrations/linear.py
:
custom_field_id = "LIN_CUSTOM_1"
issue_data["fieldValues"].append({
"fieldId": custom_field_id,
"value": triage_result.custom_field_1
})
In app/integrations/linear.py
, modify project selection:
def get_target_project(triage_result: TriageResult) -> str:
if triage_result.issue_type == "billing":
return "BIL" # Billing project
elif triage_result.customer_domain == "enterprise.com":
return "ENT" # Enterprise project
return settings.LINEAR_PROJECT_ID
In app/integrations/slack.py
, edit the Slack payload:
blocks = [
{
"type": "section",
"text": {
"type": "mrkdwn",
"text": f"π΄ *URGENT: {triage_result.summary}*\nCustomer: {triage_result.customer_domain}\n<{issue_url}|View in Linear>"
}
}
]
For higher accuracy (slower + more expensive):
TRIAGE_MODEL=claude-3-opus-20250219 python -m uvicorn app.main:app
For lower cost (faster):
TRIAGE_MODEL=claude-3-5-haiku-20241022 python -m uvicorn app.main:app
Switch from SQLite to PostgreSQL:
pip install psycopg2-binary
export DATABASE_URL=postgresql://user:password@localhost:5432/triage
python -m alembic upgrade head
pytest tests/ -v
python -m app.agents.triage_agent --email-from "customer@example.com" --subject "Payment failed" --body "We can't process payments today"
python scripts/test_email_webhook.py
docker-compose up -d
See docker-compose.yml
for production config (PostgreSQL, environment variables).
git push heroku main
heroku config:set ANTHROPIC_API_KEY=sk-ant-...
heroku config:set LINEAR_API_KEY=lin_api_...
pip install aws-wsgi
"Invalid Linear API Key"
- Verify token in
Settings > API > Personal API Keys - Ensure token has
read
andwrite
scopes
"Claude rate limit exceeded"
- Upgrade Anthropic plan or implement request queueing
- Batch emails in peak hours
"Slack notification not sent"
- Verify
SLACK_WEBHOOK_URL
is set and valid - Check Slack workspace webhook permissions
- Set
ENABLE_SLACK_NOTIFICATIONS=false
to skip errors
"Database connection error"
- For SQLite: ensure
triage.db
directory is writable - For PostgreSQL: verify host/port/credentials
- Run
python -c "from app.db import init_db; init_db()"
to reinitialize
Typical performance on Sonnet 3.5:
Email parsing: 50msClaude triage: 2-4s (network + inference)Linear issue creation: 300-800msSlack notification: 200-500msTotal end-to-end: 2.5-6s
MIT License β see LICENSE file for details.
Built with Pydantic AI, FastAPI, and Linear API.