Skip to main content

Fastn SDK for Python

Give your AI agents and apps secure, governed access to 250+ enterprise systems.

Python SDK for OpenAI, Anthropic, Gemini, and Bedrock function calling, plus a client for the fastn platform API. Fully managed OAuth, a SOC 2 Type II platform, role-based access control, and audit trails, so your agent code stays simple and your security team stays happy.

PyPI version Python License: MIT

Which client do I need?

The package ships two clients. They use different keys and endpoints, so pick by what you are building:

You want to... Use Key
Give an LLM agent tools from 250+ connectors, call connector tools, run flows, use the fastn CLI from fastn import FastnClient (this page, from Installation on) Project API key or fastn login
Embed integrations for your own customers: register customers, send setup links, read and write their CRM / calendar through the unified API, receive webhooks from fastn.platform import FastnClient (see Platform API client) Platform API key, https://api.fastn.dev

Why fastn?

Problem fastn Solution
Agents receive all tool schemas, burning tokens and increasing hallucination get_tools_for(prompt, limit=5) returns only the most relevant tools: 250+ connectors, but only 5 reach the LLM
API schemas are deeply nested, wasting context on structure SDK auto-unwraps schemas for LLMs and re-wraps for execution: flat params in, correct API structure out
Each SaaS API has its own OAuth flow, token refresh, and credential storage Fully managed OAuth vault: acquisition, auto-refresh, tenant isolation. No token management code.
Security and compliance are afterthoughts in most agent tooling SOC 2 Type II platform, role-based access control, audit trails
LLM agents need tool schemas in provider-specific formats get_tools_for("Send a Slack message", format="openai") returns ready-to-use schemas for OpenAI, Anthropic, Gemini, Bedrock
Managing connections per customer in multi-tenant apps is complex First-class tenant_id and connection_id support at every level
Building automation workflows requires stitching APIs together fastn.flows.generate("When a PR is opened, post to Slack") builds the flow for you

Installation

pip install "fastn-ai[cli]"   # SDK + the fastn CLI (recommended)
pip install fastn-ai          # SDK only, no CLI

Requires Python 3.8+. The package includes type stubs for 250+ connectors, so IDE autocomplete works out of the box. The fastn command needs the [cli] extra.

Quick Start

Log in once and add the connectors you want to call. This writes your credentials and the connector tool schemas to .fastn/ in the current directory:

fastn login                  # opens the browser, then pick a project
fastn connector sync         # fetch the connector registry
fastn connector add slack    # fetch Slack's tool schemas

Then call the connector from Python:

from fastn import FastnClient

fastn = FastnClient()        # reads .fastn/config.json
fastn.slack.send_message(channel="general", text="Hello from fastn!")

Calling a connector that has not been added raises ConnectorNotFoundError. On a server, pass api_key= and project_id= (or set FASTN_API_KEY and FASTN_PROJECT_ID) instead of fastn login. get_tools_for() needs no local registry.

Async:

from fastn import AsyncFastnClient

async with AsyncFastnClient() as fastn:
    await fastn.slack.send_message(channel="general", text="Hello!")

How It Works

fastn sits between your AI agent and 250+ SaaS APIs. The SDK handles client-side concerns (tool discovery, schema transformation, parameter routing). The platform handles server-side concerns (credential injection, access control, batch optimization, prompt safety, observability).

One-liner: Connectors provide tools. Flows compose tools. Agents run tools and flows with reasoning.

Core Capabilities

Capability What It Does Where It Runs
Dynamic tool filtering Returns only tools that match the current prompt or intent Platform
Context optimization Composes tools/skills and filters schema I/O to minimize tokens and hallucination Platform + SDK
Schema transformer Flattens nested API schemas for LLMs, re-wraps for execution SDK
Intent routing Determines which tool to use based on agent request Platform + SDK
Managed OAuth Full token lifecycle: acquisition, refresh, revocation, tenant isolation Platform
Governed access RBAC, audit trails, and enterprise compliance controls (SOC 2 Type II) Platform
Batch optimizer Groups similar calls to reduce cost and time Platform
Prompt safety Blocks unsafe or injected tool commands Platform
Observability layer Tracks cost, latency, and errors per tool call Platform + SDK CLI

Dynamic Tool Filtering

get_tools_for(prompt) sends a semantic search to the platform, which matches the prompt against the full connector registry and returns only the top N tools (default: 5). Sending a handful of tools instead of hundreds keeps the tool context small, and fewer tools also means fewer hallucinated tool calls.

# Semantic discovery: only the most relevant tools reach the LLM
tools = fastn.get_tools_for("Send a Slack message", format="openai", limit=5)

# Direct lookup: bypass semantic search when you know the connector name
tools = fastn.get_tools_for("slack tools", connector="slack", format="openai")

Context Optimization

fastn minimizes what reaches the LLM: fewer tokens, less hallucination, better compliance.

  • Tool and skill composition: the platform composes tools and skills into efficient chains, so agents receive focused context instead of raw API surface area
  • Schema I/O filtering: strips unnecessary fields from tool input and output schemas before they reach the LLM, reducing token cost
  • Schema transformation: the SDK flattens nested API wrappers (body, param) for the LLM and re-wraps them for execution:
What the API expects:   {"body": {"channel": "#general", "text": "hello"}}
What the LLM sees:      {"channel": "#general", "text": "hello"}

Combined with Dynamic Tool Filtering, the agent gets a focused payload instead of the full API surface.

Architecture

┌─────────────────────────────────────────────────────────────────────────┐
│  Your Agent                                                             │
│                                                                         │
│  1. Discovery                                                           │
│     get_tools_for(prompt) ──→ SDK ──→ POST /getTools ──→ Platform       │
│     Platform: dynamic tool filtering, intent routing                    │
│                              ←── top N tools (unwrapped schemas) ←──    │
│                                                                         │
│  2. LLM Call                                                            │
│     SDK: format schemas for provider (OpenAI / Claude / Gemini / etc.)  │
│     Send prompt + N tool schemas to LLM                                 │
│     LLM returns tool_call with flat params                              │
│                                                                         │
│  3. Execution                                                           │
│     execute(tool, params) ──→ SDK (re-wrap params) ──→ Platform         │
│     Platform: credential injection, RBAC, prompt safety, batch opt.     │
│                               ←── result ←──                            │
│                                                                         │
│  4. Observability                                                       │
│     Platform: audit trail, cost/latency/error tracking per tool         │
│     SDK CLI: per-call cost, latency, and token summary table            │
└─────────────────────────────────────────────────────────────────────────┘

Terminology

Term Definition Example
Connector An adapter to an external service. Provides tools. Slack, Jira, GitHub, Salesforce
Tool A callable action within a connector, exposed to agents/LLMs. The callable unit in MCP. slack.send_message, jira.create_issue
Flow Orchestration of multiple tools with logic, branching, retries, scheduling. "When a Jira ticket is created, post to Slack"
Connection An authenticated link between a connector and a specific account. OAuth connection to a Slack workspace
Tenant One of your customers (an organization or team) in a multi-tenant app. The platform API calls this a customer. tenant_id: "acme-corp"
Skill A reusable agent configuration stored in a project. fastn.skills.list()
Agent A goal-driven executor that calls tools/flows with reasoning. fastn agent "Send hello to Slack"
Project A container that groups connectors, flows, and tenants. project_id: "proj_xyz"
Stage An environment for isolating dev/staging/production data. "LIVE", "STAGING", "DEV"

SDKs

Package What It Does Language Status
fastn-ai Backend SDK: tool discovery and execution for agents, flows, CLI, and the platform API client (fastn.platform) Python Available
@fastn-ai/sdk Backend SDK: the platform API client (same surface as fastn.platform) and workspace tool calls. No CLI, flows, or get_tools_for TypeScript Available
@fastn-ai/embed Frontend widget: lets your end users connect their apps (OAuth and connector config) inside your product JavaScript / React Available

Configuration

Credentials are loaded from three sources (highest priority first):

  1. Constructor parameters: FastnClient(api_key="...", project_id="...")
  2. Environment variables: FASTN_API_KEY, FASTN_PROJECT_ID
  3. Config file: .fastn/config.json (created by fastn login)
# Explicit credentials (no config file needed)
fastn = FastnClient(api_key="your-api-key", project_id="your-project-id")
Variable Description
FASTN_API_KEY API key
FASTN_PROJECT_ID Project ID
FASTN_AUTH_TOKEN JWT from fastn login
FASTN_TENANT_ID Default tenant ID
FASTN_STAGE Environment: LIVE, STAGING, or DEV

LLM Agent Integration

fastn handles the three hardest parts of giving LLMs access to tools:

  1. Discovery: get_tools_for(prompt) semantically matches tools from 250+ connectors. Only the top N reach the LLM, keeping context small and hallucination low.
  2. Schema translation: schemas are flattened for LLM consumption and formatted for your provider (OpenAI, Anthropic, Gemini, Bedrock).
  3. Execution: execute(tool, params) routes through the platform, which handles credential injection, parameter re-wrapping, retries, and logging.
import json
import openai
from fastn import FastnClient

fastn = FastnClient()

# 1. Describe what you need and fastn discovers the right tools
tools = fastn.get_tools_for(
    "Send a message on Slack and create a Jira ticket",
    format="openai",   # also: anthropic, gemini, bedrock, raw
)

# 2. Send tools + user prompt to the LLM
response = openai.chat.completions.create(
    model="gpt-4o",
    messages=[{"role": "user", "content": "Send hello to #general on Slack"}],
    tools=tools,
)

# 3. The LLM returns a tool_call when it wants to use a tool
tool_call = response.choices[0].message.tool_calls[0]

# 4. Execute the tool call through fastn
result = fastn.execute(
    tool=tool_call.function.name,                      # e.g. "send_message"
    params=json.loads(tool_call.function.arguments),    # e.g. {"channel": "general", "text": "hello"}
)
print(result)

Supported LLM Providers

Format Provider Example
"openai" OpenAI, Azure OpenAI get_tools_for("Send a Slack message", format="openai")
"anthropic" Anthropic Claude get_tools_for("Create a Jira issue", format="anthropic")
"gemini" Google Gemini / Vertex AI get_tools_for("List GitHub repos", format="gemini")
"bedrock" AWS Bedrock Converse API get_tools_for("Send an email", format="bedrock")
"raw" Any (raw fastn schemas) get_tools_for("Notify team", format="raw")

Anthropic Claude Example

import anthropic
from fastn import FastnClient

fastn = FastnClient()
tools = fastn.get_tools_for("Send a message on Slack", format="anthropic")

client = anthropic.Anthropic()
response = client.messages.create(
    model="claude-sonnet-4-20250514",
    max_tokens=1024,
    messages=[{"role": "user", "content": "Send 'Build passed' to #ci"}],
    tools=tools,
)

for block in response.content:
    if block.type == "tool_use":
        result = fastn.execute(tool=block.name, params=block.input)
        print(result)

Google Gemini Example

from google import genai
from fastn import FastnClient

fastn = FastnClient()
tools = fastn.get_tools_for("Send a Slack message", format="gemini", limit=10)

client = genai.Client()
response = client.models.generate_content(
    model="gemini-2.0-flash",
    contents="Send a greeting to #general on Slack",
    # format="gemini" returns function declarations; wrap them in a Tool
    config=genai.types.GenerateContentConfig(
        tools=[genai.types.Tool(function_declarations=tools)],
    ),
)

for part in response.candidates[0].content.parts:
    if fn := part.function_call:
        result = fastn.execute(tool=fn.name, params=dict(fn.args))
        print(result)

AWS Bedrock Example

import boto3
from fastn import FastnClient

fastn = FastnClient()
tools = fastn.get_tools_for("Notify the team on Slack", format="bedrock")

bedrock = boto3.client("bedrock-runtime")
response = bedrock.converse(
    modelId="anthropic.claude-sonnet-4-20250514-v1:0",
    messages=[{"role": "user", "content": [{"text": "Notify #ops that deploy is done"}]}],
    toolConfig={"tools": tools},
)

for block in response["output"]["message"]["content"]:
    if "toolUse" in block:
        tool_use = block["toolUse"]
        result = fastn.execute(tool=tool_use["name"], params=tool_use["input"])
        print(result)

Using Connector Names Directly

For local registry lookup without an API call, pass connector names:

# Single connector
tools = fastn.get_tools_for("slack tools", connector="slack", format="openai")

# Multiple connectors: limit applies to the total across all
tools = fastn.get_tools_for(
    "project tools",
    connector=["slack", "jira", "github"],
    format="openai",
    limit=10,
)

Connector Catalog

Inspect the connector registry programmatically:

# List all connectors in the registry
connectors = fastn.connectors.list()
for c in connectors:
    print(f"{c['name']}: {c['tool_count']} tools")

# Get details for a specific connector
slack = fastn.connectors.get("slack")
print(slack["tools"])

# List all tools in a connector with full schemas
tools = fastn.get_tools("slack")
for t in tools:
    print(f"  {t['name']}: {t['description']}")

# Get a single tool's schema
tool = fastn.get_tool("slack", "send_message")
print(tool["inputSchema"])

Flows

Flows (called workflows in the fastn dashboard) chain tools across connectors. Describe one in plain English and the flow builder agent generates it; then deploy it and run it by name.

import uuid

# Generate a flow with the flow builder agent. It is a conversation: reuse the
# session id to answer its follow-up questions.
session = str(uuid.uuid4())
reply = fastn.flows.generate(
    "When a Jira ticket is created, post a summary to #engineering on Slack",
    session_id=session,
)
print(reply)  # the agent's answer: the flow it built, or questions for you
fastn.flows.generate("Use the ENG project and the #engineering channel", session_id=session)

# List flows (status filter is case-insensitive: "DEPLOYED", "DRAFT", ...)
flows = fastn.flows.list()
deployed = fastn.flows.list(status="DEPLOYED")

# Inspect a flow and the input it expects
flow = fastn.flows.get("jira_to_slack")
schema = fastn.flows.schema("jira_to_slack")   # {"fields": [...], "schema": {...}}

# Deploy, then run by flow name
fastn.flows.deploy("jira_to_slack", stage="LIVE", comment="first release")
result = fastn.flows.run("jira_to_slack", input_data={"ticket": "ENG-42"}, stage="LIVE")

# Update the schedule or enable/disable (by flow id), and delete
flow_id = flows[0]["flow_id"]
fastn.flows.update(flow_id, schedule="0 9 * * MON-FRI", enabled=True)
fastn.flows.delete(flow_id)          # also accepts a flow name

Authentication

fastn supports three authentication types at different levels. The SDK triggers connectors and flows; the platform manages OAuth token refresh and credential injection.

Auth Type Who Authenticates To What How Expiry
API Key Your app fastn platform x-fastn-api-key header Never
OAuth Token You (developer) fastn platform Authorization: Bearer JWT Auto-refreshed
Connection Your end-users External services (Slack, Jira...) OAuth vault + connection_id Platform-managed

1. API Key: App-to-Platform

Static credential that authenticates your application to the fastn platform. Create it in the fastn dashboard; it does not expire.

Your App                          fastn Platform
  │                                     │
  │  POST /executeTool                  │
  │  x-fastn-api-key: sk_live_xxx      │
  │  x-fastn-space-id: proj_abc        │
  │ ──────────────────────────────────→ │
  │                                     │  Validate API key
  │                                     │  Resolve project
  │              200 OK + result        │
  │ ←────────────────────────────────── │
fastn = FastnClient(api_key="sk_live_xxx", project_id="proj_abc")
# or: export FASTN_API_KEY=sk_live_xxx

2. OAuth Token: Developer-to-Platform

JWT obtained via browser-based login (RFC 8628 Device Authorization Grant). Used by the CLI and dashboard. Auto-refreshed with a 30-second expiry buffer.

Developer          Browser            fastn (Keycloak)
  │                   │                      │
  │  fastn login      │                      │
  │ ──────────────────────────────────────→  │
  │                   │    device_code +      │
  │  ←───────────────────  user_code         │
  │                   │                      │
  │  "Visit URL,      │                      │
  │   enter code"     │                      │
  │ ────────────────→ │                      │
  │                   │  User logs in +      │
  │                   │  enters code         │
  │                   │ ──────────────────→  │
  │                   │      authorized      │
  │                   │ ←──────────────────  │
  │                   │                      │
  │  Poll for token   │                      │
  │ ──────────────────────────────────────→  │
  │       access_token + refresh_token       │
  │ ←──────────────────────────────────────  │
  │                                          │
  │  (saved to .fastn/config.json)           │
  │                                          │
  │  POST /executeTool                       │
  │  Authorization: Bearer <jwt>             │
  │ ──────────────────────────────────────→  │
  │                                          │
  │  (on expiry: auto-refresh with 30s       │
  │   buffer using refresh_token)            │
# CLI handles this automatically:
# $ fastn login
# Tokens stored in .fastn/config.json (0o600 permissions)
fastn = FastnClient()  # Picks up auth_token from config

3. Connection: End-User-to-External-Service

OAuth connections that link your end-users to external services (Slack, GitHub, etc.) through the fastn OAuth vault. Tokens are stored server-side, auto-refreshed by the platform, and isolated per tenant. Your code never sees raw credentials.

The @fastn-ai/embed widget captures auth and connector config on the frontend. This SDK triggers connectors and flows on the backend; pass connection_id to route to the right account.

Your App (backend)       Frontend (embed widget)      fastn Platform         External Service
  │                           │                         │                       │
  │  auth.connect(            │                         │                       │
  │    connector="slack"      │                         │                       │
  │    tenant="acme")         │                         │                       │
  │ ───────────────────────────────────────────────→    │                       │
  │                           │                         │                       │
  │  { connection_id,         │                         │                       │
  │    auth_url }             │                         │                       │
  │ ←───────────────────────────────────────────────    │                       │
  │                           │                         │                       │
  │  Pass auth_url to         │                         │                       │
  │  frontend ──────────────→ │                         │                       │
  │                           │  Render login /         │                       │
  │                           │  redirect user          │                       │
  │                           │ ────────────────────────────────────────────→   │
  │                           │                         │    User authorizes    │
  │                           │                         │ ←─────────────────    │
  │                           │  Callback received      │  Store tokens in      │
  │                           │ ←───────────────────    │  OAuth vault          │
  │                           │                         │                       │
  │  auth.status(             │                         │                       │
  │    connection_id)         │                         │                       │
  │ ───────────────────────────────────────────────→    │                       │
  │  { status: "authorized" } │                         │                       │
  │ ←───────────────────────────────────────────────    │                       │
  │                           │                         │                       │
  │  execute(tool,            │                         │                       │
  │    connection_id)         │                         │                       │
  │ ───────────────────────────────────────────────→    │                       │
  │                           │                         │  Inject credentials   │
  │                           │                         │ ──────────────────→   │
  │                           │                         │       result          │
  │                           │                         │ ←──────────────────   │
  │       result              │                         │                       │
  │ ←───────────────────────────────────────────────    │                       │
  │                           │                         │                       │
  │  (on token expiry: platform auto-refreshes)         │                       │
# 1. Start an OAuth connection for your end-user
result = fastn.auth.connect(
    connector="slack",
    tenant_id="customer_acme",
    redirect_url="https://myapp.com/callback",
)
# Send the user to result["auth_url"] (or let the embed widget handle it)

# 2. Check connection status (after user completes auth)
status = fastn.auth.status(connection_id=result["connection_id"])
print(status["status"])  # "pending", "authorized", "expired"

# Or look up by connector + tenant
status = fastn.auth.status(connector="github", tenant_id="customer_acme")

# 3. Use the connection: the platform injects the credentials
fastn.slack.send_message(
    connection_id=result["connection_id"],
    channel="general", text="Hello!",
)

Custom Auth Provider

For apps with their own identity provider, configure fastn to validate end-user tokens via your userinfo endpoint.

fastn.auth.configure_custom(
    userinfo_url="https://myapp.auth0.com/userinfo",
)

Multi-Connection Support

When you have multiple connections for the same connector (e.g. two Slack workspaces):

# Per-call
fastn.slack.send_message(connection_id="conn_workspace_a", channel="general", text="Hi!")

# Or bind once
slack_a = fastn.connect("conn_workspace_a")
slack_a.send_message(channel="general", text="Hello!")

Multi-Tenant Support

Route requests to the correct tenant (customer, organization, or team):

# Per-call override
fastn.slack.send_message(tenant_id="acme", channel="general", text="Hello!")

# Constructor-level default
fastn = FastnClient(tenant_id="acme")

# Environment variable
# export FASTN_TENANT_ID=acme

# CLI flag
# fastn connector run slack send_message --tenant acme --channel general --text "Hello!"

Priority: per-call tenant_id > CLI --tenant flag > constructor param > FASTN_TENANT_ID env var > config file

Environments

Switch between LIVE, STAGING, and DEV:

dev = FastnClient(stage="DEV")
staging = FastnClient(stage="STAGING")
prod = FastnClient()  # defaults to LIVE

Or: export FASTN_STAGE=DEV

AI-Powered Mode

For quick prototyping, use natural language:

result = fastn.run("Send hello to #general on Slack")

Projects

List available projects for the authenticated user:

projects = fastn.projects.list()
for p in projects:
    print(f"{p['name']} ({p['id']})")

CLI Reference

Command Description
fastn login Authenticate with Fastn and select a project
fastn logout Log out and clear saved credentials
fastn whoami Show the current logged-in user
fastn connector ls List all available connectors (--active, --installed to filter)
fastn connector ls <name> Show tools for a specific connector
fastn connector sync Refresh connector registry, fetch tool schemas, regenerate type stubs
fastn connector add <name> [...] Fetch full tool schemas for specific connectors
fastn connector remove <name> Remove connector stubs
fastn connector run <name> <tool> Execute a connector tool
fastn connector schema <name> <tool> Print a tool's input/output schema
fastn flow ls [--status deployed] List flows
fastn flow generate Generate a flow from a plain-English prompt (interactive)
fastn flow run <flow_name> Run a flow
fastn flow deploy <flow_name> Deploy a flow to DRAFT or LIVE
fastn flow schema <flow_name> Show a flow's input/output schema
fastn flow update <flow_id> / fastn flow delete <flow_id> Update or delete a flow
fastn kit ls / fastn kit get <name> / fastn kit config Connect Kit connectors and settings
fastn skill List available agent skills
fastn agent "<prompt>" Describe a task in plain English; the agent calls the right tools
fastn version Show SDK and registry versions

fastn agent

Agentic CLI: describe what you want in natural language and the agent discovers tools, sends them to your LLM via native function calling, and executes tool calls in a loop until the task is complete.

fastn agent "Send hello to #general on Slack"
fastn agent --connector slack "List all channels"
fastn agent --eval "Create a Jira ticket for the login bug"

The first run asks you to pick an LLM provider and enter its API key (saved to .fastn/config.json).

Option Default Description
--connector -- Scope tool discovery to a specific connector
--tool -- Scope discovery to a specific tool
--max-turns 10 Maximum agentic loop iterations
--max-tools 5 Maximum number of tools passed to the LLM
--max-errors 2 Stop after this many consecutive tool errors
-y / --yes off Skip confirmation prompts before each tool call
--eval off Run LLM-based evaluation after the agent finishes
--connection-id -- Connection ID for multi-connection connectors
--tenant -- Tenant ID override
--model -- Override the LLM model (e.g. gpt-4o-mini)
--setup off Re-run the LLM provider/model setup

fastn connector run

Execute connector tools directly from the command line:

# List available tools
fastn connector run slack

# Interactive mode (prompts for each parameter)
fastn connector run slack send_message

# Inline parameters
fastn connector run slack send_message --channel general --text "Hello!"

# With tenant override (or pass the tenant as a third positional argument)
fastn connector run slack send_message --tenant acme --channel general --text "Hello!"

API Reference

FastnClient

FastnClient(
    api_key: str = None,        # fastn API key (or FASTN_API_KEY)
    project_id: str = None,     # Project ID (or FASTN_PROJECT_ID)
    auth_token: str = None,     # JWT from fastn login (or FASTN_AUTH_TOKEN)
    tenant_id: str = None,      # Tenant ID (or FASTN_TENANT_ID)
    stage: str = None,          # "LIVE", "STAGING", "DEV" (or FASTN_STAGE)
    agent_id: str = None,       # Agent ID, for agent-scoped calls
    config_path: str = None,    # Path to config.json
    timeout: float = None,      # HTTP timeout in seconds (default from config, else 30)
    max_retries: int = 3,       # Retry count for transient failures
    verbose: bool = False,      # Debug logging
)

Data Plane (tool execution):

Method Description
fastn.<connector>.<tool>(**params) Execute a tool on a connector
fastn.connect(connection_id) Bind a connection, return a proxy
fastn.execute(tool, params, ...) Execute by tool name (for LLM agents)
fastn.run(prompt) AI-powered tool discovery and execution

Control Plane (discovery):

Method Description
fastn.connectors.list() List all connectors in the registry
fastn.connectors.get(connector_name) Get connector details (name, category, tools)
fastn.get_tools(connector_name) List all tools for a connector with schemas
fastn.get_tool(connector_name, tool_name) Get one tool's schema
fastn.get_tools_for(prompt, format, limit, connector) Discover tools by prompt or connector name in LLM format

Flows:

Method Description
fastn.flows.generate(prompt, session_id=None) Generate a flow with the flow builder agent (create is an alias)
fastn.flows.list(status=None) List flows (optional, case-insensitive status filter)
fastn.flows.get(flow_name) Full flow definition
fastn.flows.schema(flow_name) Input fields the flow expects
fastn.flows.deploy(flow_name, stage="LIVE", comment="") Deploy to DRAFT or LIVE
fastn.flows.run(flow_name, input_data=None, stage=None) Run a flow
fastn.flows.get_run(run_id) Check run status and results
fastn.flows.update(flow_id, prompt=, schedule=, enabled=, answers=) Update schedule, enable/disable
fastn.flows.delete(flow_id) Delete a flow

Auth:

Method Description
fastn.auth.connect(connector, tenant_id, redirect_url) Start OAuth connection flow
fastn.auth.status(connection_id=None, connector=None, tenant_id=None) Check connection status
fastn.auth.configure_custom(userinfo_url) Register custom auth provider

Skills:

Method Description
fastn.skills.list() List agent skills in the current project

Projects:

Method Description
fastn.projects.list() List available projects

Connect Kit:

Method Description
fastn.kit.get() Connect Kit configuration for the project
fastn.kit.update(settings) Update the configuration
fastn.kit.list(query="", limit=8, offset=0) List Connect Kit connectors
fastn.kit.get_connector(connector_id) One connector's details

Requests are retried on transient failures (max_retries, default 3, with exponential backoff).

AsyncFastnClient

Same API as FastnClient, but all methods are async/await:

async with AsyncFastnClient() as fastn:
    result = await fastn.slack.send_message(channel="general", text="Hi")
    flows = await fastn.flows.list()
    skills = await fastn.skills.list()
    status = await fastn.auth.status(connection_id="conn_abc")

Error Handling

All exceptions inherit from FastnError:

from fastn import (
    FastnClient, FastnError, AuthError, ConfigError, APIError,
    ConnectorNotFoundError, ToolNotFoundError, ConnectionNotFoundError,
    OAuthError, RegistryError, FlowNotFoundError, RunNotFoundError,
)

try:
    fastn.slack.send_message(channel="general", text="Hello!")
except AuthError:
    print("Invalid credentials: check your API key")
except ConnectorNotFoundError as e:
    print(f"Connector '{e.connector_name}' not found: run fastn connector add {e.connector_name}")
except ToolNotFoundError as e:
    print(f"Tool '{e.tool_name}' not found in '{e.connector_name}'")
except APIError as e:
    print(f"HTTP {e.status_code}: {e}")
except ConfigError:
    print("Run: fastn login")
Exception When Key Attributes
FastnError Base class for all SDK errors .message, .details
AuthError Invalid or expired credentials --
ConfigError Missing API key or project ID --
APIError HTTP error from the Fastn API .status_code, .response_body
ConnectorNotFoundError Connector not in registry .connector_name
ToolNotFoundError Tool not found in connector .connector_name, .tool_name
ConnectionNotFoundError Connection ID not recognized --
FlowNotFoundError Flow not found .flow_id
RunNotFoundError Run not found .run_id
OAuthError OAuth flow failed .error_code
RegistryError Registry sync or parse failure --

IDE Autocomplete

Type stubs for the client and 250+ connectors ship in the package, so autocomplete works after pip install fastn-ai:

  • PyCharm / IntelliJ: Works automatically
  • VS Code (Pylance): Works automatically
  • mypy: Works automatically (PEP 561 py.typed marker included)

To refresh stubs with the latest connector schemas, run fastn connector sync.

Examples

Runnable scripts are in the repository:

File Contents
examples/sdk/connectors.py Calling connector tools, catalog, multi-connection, multi-tenant
examples/sdk/agents.py LLM agents with get_tools_for and execute
examples/sdk/flows.py Generating, listing, and running flows
examples/cli/cli_commands.sh Every CLI command with examples

Platform API client (fastn.platform)

The fastn platform REST API for Python: every endpoint, generated from fastn's OpenAPI spec, plus a small hand-written layer that makes the common partner flow easy. It mirrors the platform client in the Node SDK (@fastn-ai/sdk): every operation is a snake_case method on its area (fastn.embed.create_setup_link) with the operationId as an alias (createSetupLink); per-call options are keyword arguments. The Node SDK's workspace tool calls (ToolsClient, fastn-sdk-tools) are Node-only.

This is a different FastnClient from fastn.FastnClient above: it takes a platform API key from the fastn dashboard and talks to https://api.fastn.dev. It is synchronous.

import os
from fastn.platform import FastnClient

fastn = FastnClient(
    api_key=os.environ["FASTN_API_KEY"],
    # base_url="https://api.fastn.dev", timeout=60.0, retries=2,
    # on_request=lambda log: print(log), defaults={...}
)

# 1. Register a customer under your account, using YOUR id for them.
customer = fastn.customer("acme-42")
customer.register({"name": "Acme Dental"})                        # idempotent: returns the existing org on repeat

# 2. Give them a link to connect their tools (Google Calendar, HubSpot, ...), by connector slug.
link = customer.connect("googleCalendar")
print(link["url"])                                                # send this to the customer

# 3. Typed methods on whatever the customer connected: the provider is picked from their connections.
booked = customer.calendar.book(
    {"title": "Intro call", "start_time": "2026-11-03T15:00:00Z", "end_time": "2026-11-03T15:30:00Z", "timezone": "Europe/London", "attendee_email": "jane@example.com"},
    idempotency_key="booking-123", correlation_id="req-abc",      # safe to retry; traceable later
)
print(booked["id"], booked["provider"], booked["data"].get("web_url"))

customer.calendar.reschedule(booked["id"], {"start_time": "2026-11-03T16:00:00Z", "end_time": "2026-11-03T16:30:00Z"})
customer.calendar.cancel(booked["id"], idempotency_key="cancel-123")

page = customer.crm.contacts.find({"email": "jane@example.com"})  # one page (the search route has no cursor); list() pages
contact = page["records"][0] if page["records"] else customer.crm.contacts.create({"first_name": "Jane", "last_name": "Doe", "email": "jane@example.com"})
customer.crm.notes.add({"body": "Booked an intro call", "parent_id": contact["id"], "parent_type": "contact"})

# 4. What did fastn do for my request id?
customer.call_log("req-abc")

# Changes at an app, sent to your webhook as connector.event / unified.event: watch them per customer.
account_id = "..."                                                # one of the customer's accounts, from customer.connections()
w = customer.watch("hubspot", ["contact.created", "deal.stageChanged"], account_id=account_id)
customer.watches("hubspot")                                       # [{"id", "app", "events", "status", ...}]
customer.unwatch("hubspot")                                       # or unwatch(w["id"])

customer.disconnect(account_id)                                   # the customer gets connection.revoked
customer.rename_account(account_id, "Front desk calendar")
customer.update({"name": "Acme Dental Ltd"})                      # or {"status": "suspended"}

# Your webhook, once for the whole account.
hook = fastn.webhooks.create({"url": "https://app.acme.com/fastn", "eventTypes": ["connection.connected", "setup_link.completed", "connector.event", "unified.event"]})
hook["secret"]                                                    # shown once: the signing secret for parse_event
fastn.webhooks.test(hook["id"]); fastn.webhooks.deliveries(hook["id"]); fastn.webhooks.rotate_secret(hook["id"])
  • customer.calendar and customer.crm are the unified API with the fields named (the catalog's own names, start_time, first_name, ...; datetime values are sent as ISO strings). Answers are {"id", "provider", "data", "warnings"?} records or {"records", "nextCursor", "hasMore"} pages. No connected provider raises 404 NO_CONNECTED_PROVIDER, several raise 409 PROVIDER_AMBIGUOUS (pass provider=).
  • Every area is on the client directly with typed inputs: fastn.orgs.list_orgs({"type": "end_org"}), fastn.embed.get_setup_link({"id": "stp_..."}), fastn.call("getTenant", {"id": "..."}), fastn.me(). fastn.catalog.categories() / .fields("crm", "contact") / customer.catalog.providers("crm", "contact") read the unified catalog. customer.records("crm", "contact", provider="hubspot") runs any catalog entity with untyped input; customer.run_action("hubspot", "updateDeal", {...}) runs a connector's own action with the customer's connection.
  • customer.watch(app, events, account_id=, connection_id=, name=): events in plain words (EVENT_ALIASES: contact.created, deal.stageChanged, ...) or as the app names them; unknown names raise 400 EVENT_NOT_FOUND with the valid list (customer.watchable_events(app)). No account on the app raises 404 CONNECTION_NOT_FOUND, several raise 409 CONNECTION_AMBIGUOUS (pass connection_id=; one of another app is 400 CONNECTION_MISMATCH). watches(app=None) lists every page, unwatch(app | id) removes (an id that is not this customer's is 404 WATCH_NOT_FOUND); disconnect / rename_account refuse an account id that is not the customer's. HubSpot has no stage-only event: deal.stageChanged is deal.propertyChange; check propertyName == "dealstage" in the event.
  • Per-call options: idempotency_key, correlation_id, customer={"ref": ...} or {"id": ...}, installation_id, target_org, headers, extra_body, extra_query, timeout, retries. FastnClient(defaults={...}) applies options to every call.
  • Errors: non-2xx raises FastnApiError with status, code, message, details, request_id and body; network failures raise FastnNetworkError. GET calls are retried on 429/502/503/504 (default 2 retries, honouring Retry-After); a write is retried only when it carries an idempotency_key and the platform de-duplicates that operation by it (unified record writes, workflow execute).
  • Events: parse_event(secret, request.headers, raw_body) verifies sha256=HMAC-SHA256(secret, "<ts>.<body>") and parses the delivery (5-minute tolerance). paginate(fastn.events.list_events, {"outcome": "sent_to_dlq"}, page_size=100) walks limit/offset and cursor lists.
  • Also available: customer.crm.tasks / customer.crm.deals (move_stage, stages), customer.calendar.free_slots, free_intervals / slots_of, verify_event_signature, and the FastnApiError.is_not_found / is_conflict / is_rate_limited / is_auth / is_validation helpers.

Development

Working on the SDK itself (from a clone of the repository):

# Install in dev mode
pip install -e ".[dev]"

# Run all tests
make test

# Run only SDK tests
make test-sdk

# Run only CLI tests
make test-cli

# Run a single test file
make test-file F=tests/cli/test_cli_commands.py

# Or use pytest directly
python3 -m pytest tests/sdk/ -q       # SDK only
python3 -m pytest tests/cli/ -q       # CLI only
python3 -m pytest tests/ -q           # All

Generated code is checked in CI: python3 scripts/generate_platform.py --check (platform client) and python3 scripts/generate_client_stub.py --check (the fastn/__init__.pyi type stub). The platform live suite runs with LIVE=1 FASTN_API_KEY=... FASTN_TEST_CUSTOMER=... pytest tests/platform/live against api.fastn-test.dev.

Test Structure

tests/
├── sdk/                           # SDK core tests
│   ├── test_client.py             # FastnClient, AsyncFastnClient
│   ├── test_connector.py          # DynamicConnector proxy
│   ├── test_config.py             # Config loading, env vars, validation
│   ├── test_exceptions.py         # Exception hierarchy
│   ├── test_auth.py               # Auth helpers
│   ├── test_oauth.py              # OAuth device flow, token refresh
│   ├── test_projects.py           # Projects namespace
│   └── test_skills.py             # Skills namespace
├── platform/                      # fastn.platform tests (live/ runs against the API)
└── cli/                           # CLI command tests
    ├── test_cli_commands.py        # All CLI commands (sync, add, remove, list, run, agent, etc.)
    ├── test_cli_helpers.py         # CLI helper functions
    ├── test_agent_command.py       # fastn agent command
    ├── test_agent_helpers.py       # Agent helper functions
    ├── test_helpers_extended.py    # Extended helper tests (token, schema, parsing)
    ├── test_skills_command.py      # fastn skill command
    ├── test_detect_api_error.py    # API error detection across providers
    └── test_detect_languages.py    # SDK language detection for stub generation

License

MIT

Metadata

Release files for fastn-ai 0.4.1

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for fastn-ai 0.4.1
File Size Uploaded Provenance Actions
fastn_ai-0.4.1.tar.gz 726.8 kB With provenance Details for fastn_ai-0.4.1.tar.gz

Built distribution (wheel)

Table of built distributions (wheels) for fastn-ai 0.4.1
File Interpreter ABI Platform Actions
fastn_ai-0.4.1-py3-none-any.whl Python 3 none any Details for fastn_ai-0.4.1-py3-none-any.whl

Total release size: 1.6 MB

Release files / fastn_ai-0.4.1.tar.gz

Download URL fastn_ai-0.4.1.tar.gz
Size 726.8 kB
Tags Source
SHA-256 checksum
How to use checksums
ca605d6cc340a8c417a9ca17769775394c6b7ad14b90bb18137a256eebe2bc7e
BLAKE2b-256 checksum
How to use checksums
aa28f6724f76378bb31dd5e6e2c3b8cc905cad9af265fbf10e52ebc470c7760b
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via twine/7.0.0 CPython/3.13.16

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

PyPI Publish Attestation

PyPI verified that this artifact, at this checksum, originated from the publisher listed below.

Signed by GitHub Actions, verified by PyPI on Oct 30, 2026.

Transparency log

Release files / fastn_ai-0.4.1-py3-none-any.whl

Download URL fastn_ai-0.4.1-py3-none-any.whl
Size 913.8 kB
Tags Python 3
SHA-256 checksum
How to use checksums
be6b8edc781badf9be8054517c5de4ed680084d044ea5a6265132a099ad444a1
BLAKE2b-256 checksum
How to use checksums
cab55dfc9ad0469b43433cca9b051314a812f9cd0474faa14a5bbc5babe5651a
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via twine/7.0.0 CPython/3.13.16

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

PyPI Publish Attestation

PyPI verified that this artifact, at this checksum, originated from the publisher listed below.

Signed by GitHub Actions, verified by PyPI on Oct 30, 2026.

Transparency log

Security for fastn-ai 0.4.1

Provenance

Provenance describes where a file came from. On PyPI, provenance is shared via attestations, which provide a verifiable record of the build or publishing details. View details, limitations and caveats.

Full provenance

Both files in this release have been uploaded with provenance metadata.

Select from 2 files

Attestation for fastn_ai-0.4.1.tar.gz

PyPI Publish Attestation

PyPI verified that this artifact, at this checksum, originated from the publisher listed below.

Signed by GitHub Actions, verified by PyPI on Oct 30, 2026.

Transparency log

A note on package security

PyPI is a repository for distributing packages, not a service for auditing them. While third-party security researchers and our staff do their best to detect and remove malicious packages, PyPI cannot guarantee the quality, security or suitability of any given package.

To learn more about protecting yourself from malicious actors, visit our package security documentation.

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page