)]}'
{
  "commit": "912b141ace1ea02ea02c22a155487608f7d0622b",
  "tree": "4e7e56b7651d7f8be1a953b171c93f7d0425987f",
  "parents": [
    "a769ccc99b9527b36925f09a3b1a3ef22360f315"
  ],
  "author": {
    "name": "Ephraim Anierobi",
    "email": "splendidzigy24@gmail.com",
    "time": "Thu Oct 15 10:46:29 2026 +0100"
  },
  "committer": {
    "name": "Ephraim Anierobi",
    "email": "splendidzigy24@gmail.com",
    "time": "Thu Oct 15 11:00:05 2026 +0100"
  },
  "message": "Retain Dag processor work until delivery is acknowledged\n\nExpose bounded, replayable claims for callback and priority parsing requests through the Execution API. Keep ownership until acknowledgment or processor retirement, and let the scheduler clean stale metadata in bounded batches.\n",
  "tree_diff": [
    {
      "type": "modify",
      "old_id": "ec17da204975e68d768250c0e80aa755cd4037ab",
      "old_mode": 33188,
      "old_path": "airflow-core/docs/migrations-ref.rst",
      "new_id": "a0b88dc55882b24d7a9d5577ffcc6d357bafe916",
      "new_mode": 33188,
      "new_path": "airflow-core/docs/migrations-ref.rst"
    },
    {
      "type": "modify",
      "old_id": "74d479a26fa21b26b1e3f39e351b814924844f05",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/api_fastapi/execution_api/datamodels/dag_parsing.py",
      "new_id": "cbd003f4dc81528c43604e236f98651845a95fc3",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/api_fastapi/execution_api/datamodels/dag_parsing.py"
    },
    {
      "type": "modify",
      "old_id": "f799f777a7c20d9faa8cd755aa21ea4d7fb64d40",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/api_fastapi/execution_api/routes/dag_parsing.py",
      "new_id": "d0c3fe3ad3897a9421a8dc60eb1276fc390deed4",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/api_fastapi/execution_api/routes/dag_parsing.py"
    },
    {
      "type": "modify",
      "old_id": "f0b5f4f82eecf6e48feefeeb52f73d388ee421e1",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/api_fastapi/execution_api/routes/jobs.py",
      "new_id": "018e5faaab42c86e92771ed5b899fb5eda67a9c2",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/api_fastapi/execution_api/routes/jobs.py"
    },
    {
      "type": "modify",
      "old_id": "b6db627b5bcfdf6ea70e22fbb12681c2f96a318d",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/api_fastapi/execution_api/versions/v2027_02_28.py",
      "new_id": "a02678ac362373c42871da3f0fc0c99b0d423e44",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/api_fastapi/execution_api/versions/v2027_02_28.py"
    },
    {
      "type": "modify",
      "old_id": "873b519576fabf71567198d7a71ebaba059b43e5",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/config_templates/config.yml",
      "new_id": "5eb6a37879ea63431c4e2864942f6a9213b894ae",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/config_templates/config.yml"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "c5ab9877634bdceadf9f63ca0206431f7c6492b7",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/dag_processing/maintenance.py"
    },
    {
      "type": "modify",
      "old_id": "8c81af7429dc98cd388668460763a4051e164469",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/dag_processing/manager.py",
      "new_id": "19aee0476ed61d3e06815d9f87058b2d5698de8b",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/dag_processing/manager.py"
    },
    {
      "type": "modify",
      "old_id": "40e1fa976ffeb18c3803370e0c148bedc730288f",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/jobs/scheduler_job_runner.py",
      "new_id": "c24d6df58d2cfe692784143b9610c3fe25383370",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/jobs/scheduler_job_runner.py"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "d938a9ed9cadb521d5eb1090ee4b6d956ca706b9",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/migrations/versions/0150_3_5_0_add_processor_work_claims.py"
    },
    {
      "type": "modify",
      "old_id": "6295b7dfa7b7148c967c8f579b51f627a165204b",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/models/callback.py",
      "new_id": "78309784de1631f95577354d28db989c87990ecb",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/models/callback.py"
    },
    {
      "type": "modify",
      "old_id": "1665699bec197e7d1277452d1518fe8b028481cc",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/models/dagbag.py",
      "new_id": "b64ed3097d4e1e4f9769c3f91b8e7fbb5d162186",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/models/dagbag.py"
    },
    {
      "type": "modify",
      "old_id": "4d1eeac7db59da9e36b9c89129dab76c9b81fed7",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/models/dagwarning.py",
      "new_id": "25224943925bd8326e1bfd78a040ee1257105168",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/models/dagwarning.py"
    },
    {
      "type": "modify",
      "old_id": "d99e7cb1ea8bec208fec6ace754ec5aa1bb4fb50",
      "old_mode": 33188,
      "old_path": "airflow-core/src/airflow/utils/db.py",
      "new_id": "12f40b7f76a5e49999385308be54f8dc16dfb623",
      "new_mode": 33188,
      "new_path": "airflow-core/src/airflow/utils/db.py"
    },
    {
      "type": "modify",
      "old_id": "7e84d4d6745af0ddc09ecdaaef2f0e63813b5687",
      "old_mode": 33188,
      "old_path": "airflow-core/tests/unit/api_fastapi/execution_api/test_token_scope_boundaries.py",
      "new_id": "f97bd40bb968b518796a62228c6814a3416f7d1e",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/api_fastapi/execution_api/test_token_scope_boundaries.py"
    },
    {
      "type": "modify",
      "old_id": "9cb187c5e2e89eef5e15610b5f6c4e3b1b1d2b71",
      "old_mode": 33188,
      "old_path": "airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_dag_parsing.py",
      "new_id": "79ae13752b05f0c303e5a81bc5d476bd86adb9ed",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/api_fastapi/execution_api/versions/head/test_dag_parsing.py"
    },
    {
      "type": "modify",
      "old_id": "0b781ccb6b0f1e117f1715e441c2050bebd3e171",
      "old_mode": 33188,
      "old_path": "airflow-core/tests/unit/api_fastapi/execution_api/versions/v2027_02_28/test_jobs.py",
      "new_id": "4fcefa6f4e17bf03192af8624cbe5eb831fb371c",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/api_fastapi/execution_api/versions/v2027_02_28/test_jobs.py"
    },
    {
      "type": "modify",
      "old_id": "40fc6d8348c3cbfd5c4c04b58f724ae877f00827",
      "old_mode": 33188,
      "old_path": "airflow-core/tests/unit/dag_processing/bundles/test_dag_bundle_manager.py",
      "new_id": "aef28b989cedaae5c5604234b045fd5e95c06d48",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/dag_processing/bundles/test_dag_bundle_manager.py"
    },
    {
      "type": "add",
      "old_id": "0000000000000000000000000000000000000000",
      "old_mode": 0,
      "old_path": "/dev/null",
      "new_id": "8e42e2054bfb22299bfd0eee0864fb1c0d2b2e3f",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/dag_processing/test_maintenance.py"
    },
    {
      "type": "modify",
      "old_id": "a9dbbea950f79d919e7b7494e221078e962789a7",
      "old_mode": 33188,
      "old_path": "airflow-core/tests/unit/dag_processing/test_manager.py",
      "new_id": "9418be4f43d18e4f405a95abec5511de608b60a3",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/dag_processing/test_manager.py"
    },
    {
      "type": "modify",
      "old_id": "7118d08edc61ff74a2bc350a20e09209c791092d",
      "old_mode": 33188,
      "old_path": "airflow-core/tests/unit/jobs/test_scheduler_job.py",
      "new_id": "b7eb013f76e6ced5c74d3d8e3f85346e5d5c81ae",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/jobs/test_scheduler_job.py"
    },
    {
      "type": "modify",
      "old_id": "0f07d7a91924b201bad1317a96b1190b132319d8",
      "old_mode": 33188,
      "old_path": "airflow-core/tests/unit/models/test_dagwarning.py",
      "new_id": "b62d25fd48d8afd132da0a635d80449af543b167",
      "new_mode": 33188,
      "new_path": "airflow-core/tests/unit/models/test_dagwarning.py"
    },
    {
      "type": "modify",
      "old_id": "7e5fdb7fa13e0a2ff360ef6c00e7c89598ded9a8",
      "old_mode": 33188,
      "old_path": "task-sdk/src/airflow/sdk/api/datamodels/_generated.py",
      "new_id": "8489c9f98a48eeb0334d0d39d11de4a4cf71bd15",
      "new_mode": 33188,
      "new_path": "task-sdk/src/airflow/sdk/api/datamodels/_generated.py"
    }
  ]
}