airbytehq / airbytehq/airbyte-api-python-sdk

`queued` missing from `JobStatusEnum`, breaking Airflow DAGs on capacity-enforced syncs

未关闭 适合新手
#141 0 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看
主要语言
Python
星标
61
派生
27
平均合并
4 分钟
30 天内合并 PR
2

描述

## 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

1. Use a capacity-based Airbyte Cloud plan.
2. Trigger enough syncs to saturate workers.
3. 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.

贡献指南

打开贡献指南

调研方向

Locate the OpenAPI specification and the SDK's JobStatusEnum definition, then inspect how status values are generated or validated. Confirm that queued is accepted by the Jobs API or Airflow provider path and that the existing validation check covers the new status; done means queued no longer raises the reported error.

由索引模型根据 Issue 内容生成。

评估

技术栈
openapi, python
领域
api
Issue 类型
缺陷
难度
2/5
预计耗时
1-3 小时
活跃度
冷清
描述清晰度
基本清楚
新手友好度
72/100

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。