title: Unified sync endpoint for pipeline data
keywords:

- unified sync endpoint for pipeline data
- post
- unified
- sync
- endpoint
- for
- pipeline
- data


# Unified sync endpoint for pipeline data

Unified endpoint for syncing data from pipeline platforms.

#### Request Body

**`organization_id`** string required

Organization ID (org_ prefixed)

**`vector_store_id`** string required

Vector store ID (vs_ prefixed)

**`sync_mode`** string required

Sync mode: incremental (updates only) or full_refresh (complete replacement)

**`sync_timestamp`** string required

ISO 8601 timestamp of sync start

**`operations`** array of SyncOperation required

List of operations to perform

## Returns

**`status`** string

Overall sync status

**`sync_id`** string

Unique sync identifier

**`processed`** integer

Total operations processed

**`results`** object

Results breakdown by operation type

**`by_namespace`** object

Results grouped by namespace

**`processing_time_ms`** integer

Processing time in milliseconds

Example

```bash cURL
curl -X POST "https://api.aitronos.com/v1/connectors/pipeline/sync" \
  -H "X-API-Key: $FREDDY_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
  "organization_id": "org_abc123",
  "vector_store_id": "your_vector_store_id",
  "sync_mode": "your_sync_mode",
  "sync_timestamp": "your_sync_timestamp",
  "operations": []
}'
```


```python Python
import os
import requests

api_key = os.environ["FREDDY_API_KEY"]

response = requests.post(
    "https://api.aitronos.com/v1/connectors/pipeline/sync",
    headers={"X-API-Key": api_key},
    json={'organization_id': 'your_organization_id', 'vector_store_id': 'your_vector_store_id', 'sync_mode': 'your_sync_mode', 'sync_timestamp': 'your_sync_timestamp', 'operations': []}
)

print(response.json())
```


```javascript JavaScript
const apiKey = process.env.FREDDY_API_KEY;

const response = await fetch('https://api.aitronos.com/v1/connectors/pipeline/sync', {
  method: 'POST',
  headers: {
    'X-API-Key': apiKey,
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({"organization_id": "org_abc123", "vector_store_id": "your_vector_store_id", "sync_mode": "your_sync_mode", "sync_timestamp": "your_sync_timestamp", "operations": []})
});

const data = await response.json();
console.log(data);
```

**Response:**


```json 200 OK
{
  "status": "success",
  "sync_id": "abc123def456",
  "processed": 1,
  "results": {},
  "by_namespace": {},
  "processing_time_ms": 1
}
```

Errors

```json 401 Unauthorized
{
  "success": false,
  "error": {
    "code": "AUTHENTICATION_REQUIRED",
    "message": "Authentication required. Please provide a valid API key.",
    "system_message": "Missing or invalid authorization header",
    "type": "authentication_error",
    "status": 401,
    "trace_id": "req_abc123xyz",
    "timestamp": "2025-11-11T10:30:00Z",
    "details": {}
  }
}
```


```json 403 Forbidden
{
  "success": false,
  "error": {
    "code": "INSUFFICIENT_PERMISSIONS",
    "message": "You do not have permission to access this resource.",
    "system_message": "Insufficient permissions for this operation",
    "type": "authorization_error",
    "status": 403,
    "trace_id": "req_def456uvw",
    "timestamp": "2025-11-11T10:30:00Z",
    "details": {}
  }
}
```

## Related Resources

- [List Connectors](/docs/api-reference/connectors/introduction)