Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Fix CI
Browse files Browse the repository at this point in the history
pierrejeambrun committed Oct 22, 2024

Verified

This commit was signed with the committer’s verified signature.
mikekasprzak Mike Kasprzak
1 parent fc32b76 commit 3987971
Showing 3 changed files with 15 additions and 10 deletions.
2 changes: 1 addition & 1 deletion airflow/api_fastapi/core_api/routes/public/__init__.py
Original file line number Diff line number Diff line change
@@ -22,9 +22,9 @@
from airflow.api_fastapi.core_api.routes.public.dag_run import dag_run_router
from airflow.api_fastapi.core_api.routes.public.dags import dags_router
from airflow.api_fastapi.core_api.routes.public.monitor import monitor_router
from airflow.api_fastapi.core_api.routes.public.plugins import plugins_router
from airflow.api_fastapi.core_api.routes.public.pools import pools_router
from airflow.api_fastapi.core_api.routes.public.providers import providers_router
from airflow.api_fastapi.core_api.routes.public.plugins import plugins_router
from airflow.api_fastapi.core_api.routes.public.variables import variables_router

public_router = AirflowRouter(prefix="/public")
2 changes: 1 addition & 1 deletion airflow/api_fastapi/core_api/routes/public/plugins.py
Original file line number Diff line number Diff line change
@@ -30,7 +30,7 @@ async def get_plugins(
limit: QueryLimit,
offset: QueryOffset,
) -> PluginCollectionResponse:
plugins_info = get_plugin_info()
plugins_info = sorted(get_plugin_info(), key=lambda x: x["name"])
return PluginCollectionResponse(
plugins=[
PluginResponse.model_validate(plugin_info)
21 changes: 13 additions & 8 deletions tests/api_fastapi/core_api/routes/public/test_plugins.py
Original file line number Diff line number Diff line change
@@ -30,22 +30,27 @@ class TestGetConnections:
{},
13,
[
"test_plugin",
"MetadataCollectionPlugin",
"OpenLineageProviderPlugin",
"databricks_workflow",
"decreasing_priority_weight_strategy_plugin",
"edge_executor",
"hive",
"plugin-a",
"plugin-b",
"plugin-c",
"postload",
"priority_weight_strategy_plugin",
"decreasing_priority_weight_strategy_plugin",
"test_plugin",
"workday_timetable_plugin",
"MetadataCollectionPlugin",
"hive",
"databricks_workflow",
"OpenLineageProviderPlugin",
],
),
({"limit": 3, "offset": 2}, 12, ["plugin-b", "plugin-c", "postload"]),
({"limit": 1}, 13, ["test_plugin"]),
(
{"limit": 3, "offset": 2},
13,
["databricks_workflow", "decreasing_priority_weight_strategy_plugin", "edge_executor"],
),
({"limit": 1}, 13, ["MetadataCollectionPlugin"]),
],
)
def test_should_respond_200(

0 comments on commit 3987971

Please sign in to comment.