airbyte_list_jobs
List sync, reset, refresh, and clear jobs with filtering by connection, status, type, date range, and workspace. Monitor job activity and failures across Airbyte pipelines.
Instructions
List sync, reset, refresh, and clear jobs with rich filtering.
Jobs represent individual executions. Every time a connection runs (manually or on schedule), Airbyte creates a job that tracks status, duration, bytes synced, and rows synced.
When to Use: - Check recent sync activity for a specific connection. - Find failed or running jobs across workspaces. - Audit sync volume (bytes/rows) over a date range. - Monitor whether scheduled syncs are executing on time. - Check the status of a refresh or clear job.
When NOT to Use: - If you already have a job ID, use airbyte_get_job for full details. - To see pipeline definitions (schedule, streams), use airbyte_get_connection instead. - If refresh/clear jobs are not returned (older Airbyte versions), use airbyte_list_jobs_internal instead.
Filters: All filters are optional and combinable: - connection_id: restrict to one pipeline. - workspace_ids: restrict to specific workspaces. - job_type: "sync", "reset", "refresh", or "clear". Note: "refresh" and "clear" require Airbyte >= 0.63. When omitted, most versions default to sync+reset only. - status: pending, running, incomplete, failed, succeeded, or cancelled. - created_at_start / created_at_end: ISO-8601 date range (e.g. "2024-01-01T00:00:00Z"). - order_by: sort field, e.g. "createdAt|DESC" (default).
Returns: Paginated list of jobs. Each entry includes: - jobId, jobType, status, connectionId, startTime, duration, bytesSynced, rowsSynced.
Markdown format shows a heading per job with bullet fields.
JSON format returns the raw API response array.Pagination: Use limit (1–100, default 20) and offset (default 0).
Examples: Recent failed jobs for a connection: params = { "connection_id": "a1b2c3d4-...", "status": "failed", "limit": 5 } All sync jobs in the last 7 days: params = { "job_type": "sync", "created_at_start": "2024-06-01T00:00:00Z" } Refresh jobs for a connection: params = { "connection_id": "a1b2c3d4-...", "job_type": "refresh" } Latest 3 jobs, newest first: params = { "limit": 3, "order_by": "createdAt|DESC" }
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| params | Yes |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |