Summary
Airbyte Cloud started returning queued as a job status for capacity-enforced syncs, but JobStatusEnum in the SDK does not include it. This causes Airflow DAGs using the Airbyte provider to fail immediately on parse.
Error
AirflowException: 'queued' is not a valid JobStatusEnum
Environment
airbyte-api 0.53.0
apache-airflow-providers-airbyte 5.5.0
- Airbyte Cloud, capacity-based plan
Root cause
The OpenAPI spec only includes pending | running | incomplete | failed | succeeded | cancelled. The queued status is described in Cloud docs as valid for capacity-enforced syncs but is absent from the spec, so the SDK raises a validation error when it encounters it.
Impact
Production pipelines are blocked whenever workers are saturated and jobs enter queued state. This is not environment-specific — any customer on a capacity-based plan using the Jobs API or Airflow provider should hit the same failure.
Steps to reproduce
- Use a capacity-based Airbyte Cloud plan.
- Trigger enough syncs to saturate workers.
- Poll job status via the Jobs API or Airflow provider — a job in
queued state will cause a parse failure.
Ask
Add queued to JobStatusEnum in the OpenAPI spec and release a patch.
Summary
Airbyte Cloud started returning
queuedas a job status for capacity-enforced syncs, butJobStatusEnumin the SDK does not include it. This causes Airflow DAGs using the Airbyte provider to fail immediately on parse.Error
Environment
airbyte-api0.53.0apache-airflow-providers-airbyte5.5.0Root cause
The OpenAPI spec only includes
pending | running | incomplete | failed | succeeded | cancelled. Thequeuedstatus is described in Cloud docs as valid for capacity-enforced syncs but is absent from the spec, so the SDK raises a validation error when it encounters it.Impact
Production pipelines are blocked whenever workers are saturated and jobs enter
queuedstate. This is not environment-specific — any customer on a capacity-based plan using the Jobs API or Airflow provider should hit the same failure.Steps to reproduce
queuedstate will cause a parse failure.Ask
Add
queuedtoJobStatusEnumin the OpenAPI spec and release a patch.