This is an automated email from the ASF dual-hosted git repository.
jscheffl pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 8af561806b9 Remove dead auth code from Airflow2 times in Edge (#67374)
8af561806b9 is described below
commit 8af561806b98dde59a022fcc76b355af62a2a593
Author: Jens Scheffler <[email protected]>
AuthorDate: Sun May 24 22:32:53 2026 +0200
Remove dead auth code from Airflow2 times in Edge (#67374)
---
.../src/airflow/providers/edge3/worker_api/auth.py | 8 --------
.../providers/edge3/worker_api/datamodels.py | 24 +---------------------
2 files changed, 1 insertion(+), 31 deletions(-)
diff --git a/providers/edge3/src/airflow/providers/edge3/worker_api/auth.py
b/providers/edge3/src/airflow/providers/edge3/worker_api/auth.py
index 6e9ba46ba87..090f65bfc92 100644
--- a/providers/edge3/src/airflow/providers/edge3/worker_api/auth.py
+++ b/providers/edge3/src/airflow/providers/edge3/worker_api/auth.py
@@ -32,7 +32,6 @@ from jwt import (
from airflow.api_fastapi.auth.tokens import JWTValidator
from airflow.providers.common.compat.sdk import conf
-from airflow.providers.edge3.worker_api.datamodels import JsonRpcRequestBase
# noqa: TCH001
log = logging.getLogger(__name__)
@@ -93,13 +92,6 @@ def jwt_token_authorization(method: str, authorization: str):
_forbidden_response("Unable to authenticate API via token.")
-def jwt_token_authorization_rpc(
- body: JsonRpcRequestBase, authorization: str = Header(description="JWT
Authorization Token")
-):
- """Check if the JWT token is correct for JSON PRC requests."""
- jwt_token_authorization(body.method, authorization)
-
-
def jwt_token_authorization_rest(
request: Request, authorization: str = Header(description="JWT
Authorization Token")
):
diff --git
a/providers/edge3/src/airflow/providers/edge3/worker_api/datamodels.py
b/providers/edge3/src/airflow/providers/edge3/worker_api/datamodels.py
index dac49485e42..7edaa1ce5d2 100644
--- a/providers/edge3/src/airflow/providers/edge3/worker_api/datamodels.py
+++ b/providers/edge3/src/airflow/providers/edge3/worker_api/datamodels.py
@@ -17,10 +17,7 @@
from __future__ import annotations
from datetime import datetime
-from typing import (
- Annotated,
- Any,
-)
+from typing import Annotated
from fastapi import Path
from pydantic import BaseModel, Field
@@ -44,25 +41,6 @@ class WorkerApiDocs:
state = Path(title="Task State", description="State of the assigned task
under execution.")
-class JsonRpcRequestBase(BaseModel):
- """Base JSON RPC request model to define just the method."""
-
- method: Annotated[
- str,
- Field(description="Fully qualified python module method name that is
called via JSON RPC."),
- ]
-
-
-class JsonRpcRequest(JsonRpcRequestBase):
- """JSON RPC request model."""
-
- jsonrpc: Annotated[str, Field(description="JSON RPC Version",
examples=["2.0"])]
- params: Annotated[
- dict[str, Any] | None,
- Field(description="Dictionary of parameters passed to the method."),
- ]
-
-
class EdgeJobBase(BaseModel):
"""Basic attributes of a job on the edge worker."""
