---
title: "Create Deal Sync Run"
method: POST
path: "/api/pipeline/deal-sync"
tags: ["pipeline"]
---

# Create Deal Sync Run

`POST /api/pipeline/deal-sync`

Start a fast-cycle deal sync for the org.

Enqueues a `pipeline_deal_sync` background job. The dispatcher in
`services/job_processor.py` routes it to the deterministic Python
sweep (`run_deal_sync_for_org`) — no Managed Agent invocation.

The hourly scheduled routine calls the same underlying sweep directly;
this endpoint is available for manual triggering / ops. ``force=true``
bypasses the normal sparse email cadence and stale-check window for a
user-requested catch-up; the per-run safety cap and per-deal idempotency
still apply.

## Query parameters

- `force` boolean
- `user_id` string, nullable
- `org_id` string, nullable

## Response `200`

Successful Response

- unknown

## Other responses

- `422` — Validation Error

---

[API](https://skmtc.net/every/apis/every-api.md) · [All operations](https://skmtc.net/every/apis/every-api/llms.txt) · [OpenAPI document](https://skmtc-service-staging.skmtc.workers.dev/v1/apis/every/every-api/versions/f8600f7a4ae3/schema)