Airbyte Cloud Jobs
Tasks that create and monitor Airbyte Cloud jobs for a connection
Airbyte
CertifiedTasks that trigger and monitor Airbyte sync and reset jobs in self-hosted Airbyte and Airbyte Cloud
Use this plugin to orchestrate Airbyte connection jobs from Kestra, including starting syncs, running resets, and waiting for job completion. Choose the self-hosted connection tasks or the Airbyte Cloud job tasks based on your Airbyte deployment and authentication model.
Airbyte
Certified
Tasks that trigger and monitor Airbyte sync and reset jobs in self-hosted Airbyte and Airbyte Cloud
Use this plugin to orchestrate Airbyte connection jobs from Kestra, including starting syncs, running resets, and waiting for job completion. Choose the self-hosted connection tasks or the Airbyte Cloud job tasks based on your Airbyte deployment and authentication model.
How to use the Airbyte plugin
Trigger and monitor Airbyte syncs from Kestra flows — with separate task packages for self-hosted Airbyte and Airbyte Cloud.
Authentication
Self-hosted (connections.*): set url to your Airbyte instance URL. For authenticated instances, set username and password, or token for bearer token auth. For OAuth M2M, set applicationCredentials.clientId and applicationCredentials.clientSecret.
Airbyte Cloud (cloud.jobs.*): set clientId and clientSecret from your Airbyte Cloud workspace API credentials, or set token directly. Basic auth (username/password) is also supported as a fallback when neither is set.
Store secrets in secrets and set connection properties on each task.
Tasks
Self-hosted — connections.Sync triggers a sync by connectionId and waits for completion by default (wait: true). If a sync is already running for the connection, onActiveSync controls what happens: ADOPT (default) attaches to the in-flight job and polls it to completion instead of triggering a new sync; FAIL fails the task immediately; SKIP succeeds immediately with alreadyRunning: true and a null jobId, without starting or queuing a second sync. failOnActiveSync is deprecated but still supported: when set, it overrides onActiveSync (true → FAIL, false → SKIP). Control polling with pollFrequency (default 1 second) and cap wait time with maxDuration (default 60 minutes) — for an adopted job, maxDuration is counted from the moment it is adopted, not from the job's actual start time. connections.CheckStatus polls an existing sync job by jobId until it reaches a terminal state.
Airbyte Cloud — cloud.jobs.Sync triggers a Cloud sync by connectionId and waits by default. cloud.jobs.Reset resets a connection's state. Both support wait, maxDuration, and pollFrequency with the same defaults.
