div
strong
🔨 In Development
 — This section is still being developed and may change.

Unified endpoint for syncing data from pipeline platforms.

Supports both incremental and full_refresh sync modes. Handles upsert and delete operations atomically in a single request.

**Authentication**: Pipeline Connector API Key required (`X-API-Key` header)

## Request Body

**`organization_id`** string required

Organization ID (org_ prefixed string).

**`sync_mode`** string required

Sync mode: `incremental` or `full_refresh`.

**`operations`** array required

List of sync operations to perform. Each operation contains action, id, and namespace.

**`sync_timestamp`** string required

ISO 8601 timestamp of when the sync was initiated.

**`vector_store_id`** string required

Vector store ID where data should be synced.

## Sync Modes

- **incremental** - Process only the operations provided (updates/deletes)
- **full_refresh** - Clear all records in affected namespaces, then insert new data


## Rate Limits

- 100 requests per minute per organization
- Maximum 5000 operations per request


## Returns

Returns sync results with processed count, upserted/deleted counts, and breakdown by namespace.


```bash cURL
curl -X POST https://api.aitronos.com/v1/pipeline/sync \
  -H "X-API-Key: $PIPELINE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "organization_id": "org_abc123",
    "sync_mode": "incremental",
    "operations": [
      {"action": "upsert", "id": "task_123", "namespace": "clickup_tasks"}
    ]
  }'
```


```python Python
import os
import requests

api_key = os.environ["PIPELINE_API_KEY"]
response = requests.post(
    "https://api.aitronos.com/v1/pipeline/sync",
    headers={"X-API-Key": api_key},
    json={
        "organization_id": "org_abc123",
        "sync_mode": "incremental",
        "operations": [
            {"action": "upsert", "id": "task_123", "namespace": "clickup_tasks"}
        ]
    }
)
result = response.json()
```


```javascript JavaScript
const apiKey = process.env.PIPELINE_API_KEY;
const response = await fetch(
  'https://api.aitronos.com/v1/pipeline/sync',
  {
    method: 'POST',
    headers: {
      'X-API-Key': apiKey,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      organization_id: 'org_abc123',
      sync_mode: 'incremental',
      operations: [
        {action: 'upsert', id: 'task_123', namespace: 'clickup_tasks'}
      ]
    })
  }
);
const result = await response.json();
```

## Response


```json
{
  "status": "success",
  "sync_id": "sync_abc123def456",
  "processed": 150,
  "results": {
    "upserted": 145,
    "deleted": 5,
    "failed": 0
  },
  "by_namespace": {
    "clickup_spaces": {
      "upserted": 12,
      "deleted": 1,
      "failed": 0
    },
    "clickup_tasks": {
      "upserted": 133,
      "deleted": 4,
      "failed": 0
    }
  },
  "processing_time_ms": 1234
}
```