airflow.providers.edge3.worker_api.auth¶

Attributes¶

log

Classes¶

`WorkerTokenAuthorization`	Result of authorizing an OIDC worker token beyond signature verification.
`WorkerTokenContext`	Request context passed to a `[edge] jwt_verifier` alongside the token claims.

Functions¶

`jwt_validator`()
`jwt_validate`(authorization)
`jwt_token_authorization`(method, authorization)	Check if the JWT token is correct.
`jwt_token_authorization_rest`(request[, authorization])	Check if the JWT token is correct for REST API requests.

Module Contents¶

airflow.providers.edge3.worker_api.auth.log[source]¶

class airflow.providers.edge3.worker_api.auth.WorkerTokenAuthorization[source]¶

Bases: TypedDict

Result of authorizing an OIDC worker token beyond signature verification.

Returned by a [edge] jwt_verifier callable to answer “may this token act as an edge worker?”. authorized must be True for the request to proceed; a falsy result (or a raised exception) rejects it.

authorized: bool[source]¶

class airflow.providers.edge3.worker_api.auth.WorkerTokenContext[source]¶

Request context passed to a [edge] jwt_verifier alongside the token claims.

method: str[source]¶: The requested Edge worker API path after the /edge_worker/v1/ prefix.

airflow.providers.edge3.worker_api.auth.jwt_validator()[source]¶

async airflow.providers.edge3.worker_api.auth.jwt_validate(authorization)[source]¶

async airflow.providers.edge3.worker_api.auth.jwt_token_authorization(method, authorization)[source]¶

Check if the JWT token is correct.

async airflow.providers.edge3.worker_api.auth.jwt_token_authorization_rest(request, authorization=Header(description='JWT Authorization Token'))[source]¶

Check if the JWT token is correct for REST API requests.