get_xcom_entries
Retrieve XCom entries from Apache Airflow by specifying DAG ID, run ID, task ID, and optional parameters like key, limit, and offset for targeted data extraction.
Instructions
Get all XCom entries
Input Schema
Name | Required | Description | Default |
---|---|---|---|
dag_id | Yes | ||
dag_run_id | Yes | ||
limit | No | ||
map_index | No | ||
offset | No | ||
task_id | Yes | ||
xcom_key | No |
Input Schema (JSON Schema)
{
"properties": {
"dag_id": {
"title": "Dag Id",
"type": "string"
},
"dag_run_id": {
"title": "Dag Run Id",
"type": "string"
},
"limit": {
"anyOf": [
{
"type": "integer"
},
{
"type": "null"
}
],
"default": null,
"title": "Limit"
},
"map_index": {
"anyOf": [
{
"type": "integer"
},
{
"type": "null"
}
],
"default": null,
"title": "Map Index"
},
"offset": {
"anyOf": [
{
"type": "integer"
},
{
"type": "null"
}
],
"default": null,
"title": "Offset"
},
"task_id": {
"title": "Task Id",
"type": "string"
},
"xcom_key": {
"anyOf": [
{
"type": "string"
},
{
"type": "null"
}
],
"default": null,
"title": "Xcom Key"
}
},
"required": [
"dag_id",
"dag_run_id",
"task_id"
],
"title": "get_xcom_entriesArguments",
"type": "object"
}