Source code for airflow.providers.edge3.worker_api.app

# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements.  See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership.  The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License.  You may obtain a copy of the License at
#
#   http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied.  See the License for the
# specific language governing permissions and limitations
# under the License.
from __future__ import annotations

from pathlib import Path

from fastapi import FastAPI
from fastapi.staticfiles import StaticFiles

from airflow.providers.edge3.worker_api.routes.health import health_router
from airflow.providers.edge3.worker_api.routes.jobs import jobs_router
from airflow.providers.edge3.worker_api.routes.logs import logs_router
from airflow.providers.edge3.worker_api.routes.ui import ui_router
from airflow.providers.edge3.worker_api.routes.worker import worker_router




[docs]
def create_edge_worker_api_app() -> FastAPI:
    """Create FastAPI app for edge worker API."""
    edge_worker_api_app = FastAPI(
        title="Airflow Edge Worker API",
        description=(
            "This is Airflow Edge Worker API - this is a the access endpoint for workers running on remote "
            "sites serving for Apache Airflow jobs. It also serves for the Edge Worker UI and provides "
            "endpoints for React web app.\n"
            "All endpoints under ``/edge_worker/v1`` are used by remote workers and need a specific JWT token.\n"
            "All endpoints under ``/edge_worker/ui`` are used by UI and can be accessed with normal authentication. "
            "Please assume UI endpoints to change and not be stable."
        ),
    )

    edge_worker_api_app.include_router(jobs_router, prefix="/v1")
    edge_worker_api_app.include_router(logs_router, prefix="/v1")
    edge_worker_api_app.include_router(worker_router, prefix="/v1")
    edge_worker_api_app.include_router(health_router, prefix="/v1")
    edge_worker_api_app.include_router(ui_router, prefix="/ui")

    # Fix mimetypes to serve cjs files correctly
    import mimetypes

    if ".cjs" not in mimetypes.suffix_map:
        mimetypes.add_type("application/javascript", ".cjs")

    www_files = Path(__file__).parents[1] / "plugins" / "www"
    edge_worker_api_app.mount(
        "/static",
        StaticFiles(directory=(www_files / "dist").absolute(), html=True),
        name="react_static_plugin_files",
    )
    edge_worker_api_app.mount(
        "/res",
        StaticFiles(directory=(www_files / "src" / "res").absolute(), html=True),
        name="react_res_plugin_files",
    )

    return edge_worker_api_app

Was this entry helpful?