Skip to content

Commit

Permalink
Remove internal-api command
Browse files Browse the repository at this point in the history
This PR removes CLI and openapi specification for the API.

Part of apache#44436
  • Loading branch information
potiuk committed Nov 28, 2024
1 parent 5e38319 commit f175b91
Show file tree
Hide file tree
Showing 11 changed files with 0 additions and 775 deletions.
1 change: 0 additions & 1 deletion .pre-commit-config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -607,7 +607,6 @@ repos:
(?x)
^airflow/api_connexion/openapi/v1.yaml$|
^airflow/ui/openapi-gen/|
^airflow/cli/commands/internal_api_command.py$|
^airflow/cli/commands/fastapi_api_command.py$|
^airflow/cli/commands/webserver_command.py$|
^airflow/config_templates/|
Expand Down
16 changes: 0 additions & 16 deletions airflow/api_internal/__init__.py

This file was deleted.

16 changes: 0 additions & 16 deletions airflow/api_internal/endpoints/__init__.py

This file was deleted.

22 changes: 0 additions & 22 deletions airflow/api_internal/endpoints/health_endpoint.py

This file was deleted.

246 changes: 0 additions & 246 deletions airflow/api_internal/endpoints/rpc_api_endpoint.py

This file was deleted.

33 changes: 0 additions & 33 deletions airflow/api_internal/gunicorn_config.py

This file was deleted.

13 changes: 0 additions & 13 deletions airflow/api_internal/internal_api_call.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,27 +17,14 @@

from __future__ import annotations

import logging
from functools import wraps
from http import HTTPStatus
from typing import Callable, TypeVar

from airflow.exceptions import AirflowException
from airflow.typing_compat import ParamSpec

PS = ParamSpec("PS")
RT = TypeVar("RT")

logger = logging.getLogger(__name__)


class AirflowHttpException(AirflowException):
"""Raise when there is a problem during an http request on the internal API decorator."""

def __init__(self, message: str, status_code: HTTPStatus):
super().__init__(message)
self.status_code = status_code


def internal_api_call(func: Callable[PS, RT]) -> Callable[PS, RT]:
@wraps(func)
Expand Down
Loading

0 comments on commit f175b91

Please sign in to comment.