List Sync Jobs | Airweave

Retrieve the sync job history for a source connection.

Returns a list of sync jobs ordered by creation time (newest first). Each job includes status, timing information, and entity counts.

Job statuses:

PENDING: Job is queued, waiting for the worker to pick it up
RUNNING: Sync is actively pulling and processing data
COMPLETED: Sync finished successfully
FAILED: Sync encountered an unrecoverable error
CANCELLING: Cancellation has been requested. The worker is gracefully stopping the pipeline and cleaning up destination data.
CANCELLED: Sync was cancelled. The worker has fully stopped and destination data cleanup has been scheduled.

Retrieve the sync job history for a source connection. Returns a list of sync jobs ordered by creation time (newest first). Each job includes status, timing information, and entity counts. Job statuses: - **PENDING**: Job is queued, waiting for the worker to pick it up - **RUNNING**: Sync is actively pulling and processing data - **COMPLETED**: Sync finished successfully - **FAILED**: Sync encountered an unrecoverable error - **CANCELLING**: Cancellation has been requested. The worker is gracefully stopping the pipeline and cleaning up destination data. - **CANCELLED**: Sync was cancelled. The worker has fully stopped and destination data cleanup has been scheduled.

Authentication

x-api-keystring

API Key authentication via header

Path parameters

source_connection_idstringRequiredformat: "uuid"

Unique identifier of the source connection (UUID)

Query parameters

limitintegerOptional1-1000Defaults to 100

Maximum number of jobs to return (1-1000)

Response

List of sync jobs

idstringformat: "uuid"

Unique identifier of the sync job

source_connection_idstringformat: "uuid"

ID of the source connection this job belongs to

statusenum

Current status: PENDING, RUNNING, COMPLETED, FAILED, CANCELLED, or CANCELLING

started_atstring or nullformat: "date-time"

When the job started execution (ISO 8601)

completed_atstring or nullformat: "date-time"

When the job finished (ISO 8601). Null if still running.

duration_secondsdouble or null

Total execution time in seconds. Null if still running.

entities_insertedinteger or nullDefaults to 0

Number of new entities created during this sync

entities_updatedinteger or nullDefaults to 0

Number of existing entities updated during this sync

entities_deletedinteger or nullDefaults to 0

Number of entities removed during this sync

entities_failedinteger or nullDefaults to 0

Number of entities that failed to process

errorstring or null

Error message if the job failed

error_detailsmap from strings to any or null

Additional error context for debugging

1	from airweave import AirweaveSDK
2
3	client = AirweaveSDK(
4	api_key="YOUR_API_KEY",
5	)
6	client.source_connections.get_source_connection_jobs(
7	source_connection_id="550e8400-e29b-41d4-a716-446655440000",
8	limit=100,
9	)

1	[
2	{
3	"id": "770e8400-e29b-41d4-a716-446655440002",
4	"source_connection_id": "550e8400-e29b-41d4-a716-446655440000",
5	"status": "created",
6	"started_at": "2024-01-15T09:30:00Z",
7	"completed_at": "2024-01-15T09:30:00Z",
8	"duration_seconds": 1.1,
9	"entities_inserted": 0,
10	"entities_updated": 0,
11	"entities_deleted": 0,
12	"entities_failed": 0,
13	"error": "string",
14	"error_details": {}
15	}
16	]

Authentication

Path parameters

Query parameters

Response

Errors