Get started with Precipiq

pip install precipiq

npm install precipiq
# or: pnpm add precipiq
# or: yarn add precipiq

# demo.py
from precipiq import Precipiq

# ``enable_batching=False`` for the demo so the call ships
# synchronously and ``log_decision`` returns the server receipt
# instead of ``None``.  In production, leave batching on for
# throughput and call ``pq.flush()`` at shutdown.
pq = Precipiq(
    api_key="pq_test_demo_key_REPLACE_ME",
    enable_batching=False,
)

receipt = pq.log_decision(
    agent_id="pricing-bot",
    action_type="discount_offer",
    inputs={"customer_id": "cust_123", "tier": "gold"},
    outputs={"discount_pct": 15},
    confidence=0.82,
    human_in_loop=False,
)
# ``receipt`` is a dict keyed by the server's snake_case schema.
print("decision id:", receipt["decision_id"])
print("chain hash:", receipt["hash"])

// demo.ts
import { Precipiq } from 'precipiq';

// ``enableBatching: false`` for the demo so the call ships
// synchronously and returns a receipt.  In production, leave
// batching on and call ``pq.flush()`` at shutdown.
const pq = new Precipiq('pq_test_demo_key_REPLACE_ME', {
  enableBatching: false,
});

const receipt = await pq.logDecision({
  agentId: 'pricing-bot',
  actionType: 'discount_offer',
  inputs: { customer_id: 'cust_123', tier: 'gold' },
  outputs: { discount_pct: 15 },
  confidence: 0.82,
  humanInLoop: false,
});

if (receipt) {
  console.log('decision id:', receipt.decisionId);
  console.log('chain hash:', receipt.hash);
}

@pq.track(agent_id="pricing-bot", action_type="discount_offer")
def compute_discount(customer_id: str, tier: str) -> dict:
    # Your real business logic:
    pct = 15 if tier == "gold" else 5
    return {"discount_pct": pct}

compute_discount("cust_456", "silver")
# The decision, inputs, and outputs are recorded on every call.

const computeDiscount = pq.track(
  'pricing-bot',
  'discount_offer',
  async (args: { customerId: string; tier: string }) => {
    const pct = args.tier === 'gold' ? 15 : 5;
    return { discountPct: pct };
  },
);

await computeDiscount({ customerId: 'cust_456', tier: 'silver' });

# ``receipt`` came from step 2.
# The second arg is the ``financial_event_id`` returned by your Stripe integration.
pq.link_outcome(
    receipt["decision_id"],
    "fev_abc",
    correlation_strength=1.0,       # 0..1 — strongest when directly caused
    link_type="revenue",            # "revenue" | "cost" | "liability" | "neutral"
)

if (receipt) {
  await pq.linkOutcome(
    receipt.decisionId,
    'fev_abc',
    {
      correlationStrength: 1.0,
      linkType: 'revenue',
    },
  );
}

pnl = pq.get_ai_pnl(start="2026-04-01", end="2026-04-30")
# ``pnl`` is a dict keyed by the server's snake_case schema.
if pnl is not None:
    print(pnl["total_revenue_attributed"], pnl["currency"])
    print(pnl["net_ai_impact"])

const pnl = await pq.getAiPnl({ start: '2026-04-01', end: '2026-04-30' });
if (pnl) {
  console.log(pnl.totalRevenueAttributed, pnl.currency);
  console.log(pnl.netAiImpact);
}