AIP-84 Migrate backfill API to fast api (#43496)

apache · Nov 4, 2024 · 30147ff · 30147ff
1 parent 20e6517
commit 30147ff
Show file tree

Hide file tree

Showing 20 changed files with 2,597 additions and 2,026 deletions.
diff --git a/airflow/api_connexion/endpoints/backfill_endpoint.py b/airflow/api_connexion/endpoints/backfill_endpoint.py
diff --git a/airflow/api_connexion/openapi/v1.yaml b/airflow/api_connexion/openapi/v1.yaml
@@ -245,155 +245,6 @@ servers:
     description: Apache Airflow Stable API.
 
 paths:
-  # Database entities
-  /backfills:
-    get:
-      summary: List backfills
-      x-openapi-router-controller: airflow.api_connexion.endpoints.backfill_endpoint
-      operationId: list_backfills
-      tags: [Backfill]
-      parameters:
-        - name: dag_id
-          in: query
-          schema:
-            type: string
-          required: true
-          description: |
-            List backfills for this dag.
-      responses:
-        "200":
-          description: Success.
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/BackfillCollection"
-        "401":
-          $ref: "#/components/responses/Unauthenticated"
-        "403":
-          $ref: "#/components/responses/PermissionDenied"
-
-    post:
-      summary: Create a backfill job.
-      x-openapi-router-controller: airflow.api_connexion.endpoints.backfill_endpoint
-      operationId: create_backfill
-      tags: [Backfill]
-      requestBody:
-        required: true
-        content:
-          application/json:
-            schema:
-              $ref: "#/components/schemas/Backfill"
-      responses:
-        "200":
-          description: Success.
-          content:
-            application/json:
-              schema:
-                $ref: "#/components/schemas/Backfill"
-        "400":
-          $ref: "#/components/responses/BadRequest"
-        "401":
-          $ref: "#/components/responses/Unauthenticated"
-        "403":
-          $ref: "#/components/responses/PermissionDenied"
-
-  /backfills/{backfill_id}:
-    parameters:
-      - $ref: "#/components/parameters/BackfillIdPath"
-    get:
-        summary: Get a backfill
-        x-openapi-router-controller: airflow.api_connexion.endpoints.backfill_endpoint
-        operationId: get_backfill
-        tags: [Backfill]
-        responses:
-          "200":
-            description: Success.
-            content:
-              application/json:
-                schema:
-                  $ref: "#/components/schemas/Backfill"
-          "401":
-            $ref: "#/components/responses/Unauthenticated"
-          "403":
-            $ref: "#/components/responses/PermissionDenied"
-          "404":
-            $ref: "#/components/responses/NotFound"
-
-  /backfills/{backfill_id}/pause:
-    parameters:
-      - $ref: "#/components/parameters/BackfillIdPath"
-    post:
-        summary: Pause a backfill
-        x-openapi-router-controller: airflow.api_connexion.endpoints.backfill_endpoint
-        operationId: pause_backfill
-        tags: [Backfill]
-        responses:
-          "200":
-            description: Success.
-            content:
-              application/json:
-                schema:
-                  $ref: "#/components/schemas/Backfill"
-          "401":
-            $ref: "#/components/responses/Unauthenticated"
-          "403":
-            $ref: "#/components/responses/PermissionDenied"
-          "404":
-            $ref: "#/components/responses/NotFound"
-          "409":
-            $ref: "#/components/responses/Conflict"
-
-  /backfills/{backfill_id}/unpause:
-    parameters:
-      - $ref: "#/components/parameters/BackfillIdPath"
-    post:
-        summary: Pause a backfill
-        x-openapi-router-controller: airflow.api_connexion.endpoints.backfill_endpoint
-        operationId: unpause_backfill
-        tags: [Backfill]
-        responses:
-          "200":
-            description: Success.
-            content:
-              application/json:
-                schema:
-                  $ref: "#/components/schemas/Backfill"
-          "401":
-            $ref: "#/components/responses/Unauthenticated"
-          "403":
-            $ref: "#/components/responses/PermissionDenied"
-          "404":
-            $ref: "#/components/responses/NotFound"
-          "409":
-            $ref: "#/components/responses/Conflict"
-
-  /backfills/{backfill_id}/cancel:
-    parameters:
-      - $ref: "#/components/parameters/BackfillIdPath"
-    post:
-        summary: Cancel a backfill
-        description: |
-          When a backfill is cancelled, all queued dag runs will be marked as failed.
-          Running dag runs will be allowed to continue.
-        x-openapi-router-controller: airflow.api_connexion.endpoints.backfill_endpoint
-        operationId: cancel_backfill
-        tags: [Backfill]
-        responses:
-          "200":
-            description: Success.
-            content:
-              application/json:
-                schema:
-                  $ref: "#/components/schemas/Backfill"
-          "401":
-            $ref: "#/components/responses/Unauthenticated"
-          "403":
-            $ref: "#/components/responses/PermissionDenied"
-          "404":
-            $ref: "#/components/responses/NotFound"
-          "409":
-            $ref: "#/components/responses/Conflict"
-
   # Database entities
   /connections:
     get: