soltanianalytics opened a new issue #14331:
URL: https://github.com/apache/airflow/issues/14331
**Apache Airflow version**: 2.0.1
**Environment**: Docker on Win 10 with WSL, image based on
`apache/airflow:2.0.1-python3.8`
**What happened**:
I'm using the airflow API and the following (what I believe to be a) bug
popped up:
```Python
>>> import requests
>>> r =
requests.get("http://localhost:8084/api/v1/dags/~/dagRuns/~/taskInstances";,
auth=HTTPBasicAuth('username', 'password'))
>>> r.status_code
500
>>> print(r.text)
{
"detail": "'removed' is not one of ['success', 'running', 'failed',
'upstream_failed', 'skipped', 'up_for_retry', 'up_for_reschedule', 'queued',
'none', 'scheduled']\n\nFailed validating 'enum' in
schema['allOf'][0]['properties']['task_instances']['items']['properties']['state']:\n
{'description': 'Task state.',\n 'enum': ['success',\n
'running',\n 'failed',\n 'upstream_failed',\n
'skipped',\n 'up_for_retry',\n
'up_for_reschedule',\n 'queued',\n 'none',\n
'scheduled'],\n 'nullable': True,\n 'type': 'string',\n
'x-scope': ['',\n
'#/components/schemas/TaskInstanceCollection',\n
'#/components/schemas/TaskInstance']}\n\nOn
instance['task_instances'][16]['state']:\n 'removed'",
"status": 500,
"title": "Response body does not conform to specification",
"type":
"https://airflow.apache.org/docs/2.0.1rc2/stable-rest-api-ref.html#section/Errors/Unknown";
}
>>> print(r.json()["detail"])
'removed' is not one of ['success', 'running', 'failed', 'upstream_failed',
'skipped', 'up_for_retry', 'up_for_reschedule', 'queued', 'none', 'scheduled']
Failed validating 'enum' in
schema['allOf'][0]['properties']['task_instances']['items']['properties']['state']:
{'description': 'Task state.',
'enum': ['success',
'running',
'failed',
'upstream_failed',
'skipped',
'up_for_retry',
'up_for_reschedule',
'queued',
'none',
'scheduled'],
'nullable': True,
'type': 'string',
'x-scope': ['',
'#/components/schemas/TaskInstanceCollection',
'#/components/schemas/TaskInstance']}
On instance['task_instances'][16]['state']:
'removed'
```
This happened after I changed a DAG in the corresponding instance, thus a
task was removed from a DAG while the DAG was running.
**What you expected to happen**:
Give me all task instances, whether including the removed ones or not is up
to the airflow team to decide (no preferences from my side, though I'd guess it
makes more sense to supply all data as it is available).
**How to reproduce it**:
- Run airflow
- Create a DAG with multiple tasks
- While the DAG is running, remove one of the tasks (ideally one that did
not yet run)
- Make the API call as above
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
