User is able to register multiple plugins using same name

[atul-astronomer]

Apache Airflow version

main (development)

If "Other Airflow 2 version" selected, which one?

No response

What happened?

User is able to register multiple FastAPI plugins using same name

On UI, only 1 plugin is visible

What you think should happen instead?

No response

How to reproduce

Register 2 FastAPI plugins using same name and see no error is coming but on UI, only 1 plugin is listed

from airflow.plugins_manager import AirflowPlugin
from fastapi import FastAPI

my_app = FastAPI()

@my_app.get("/ping")
async def ping():
    return {"message": "pong"}

class MyFastAPIPlugin(AirflowPlugin):
    name = "my_fastapi_plugin"
    fastapi_apps = [
        {
            "name": "example_api",
            "app": my_app,
            "url_prefix": "/example"
        }
    ]

@my_app.get("/hello")
async def ping():
    return {"message": "Hello"}

class MyFastAPIPlugin2(AirflowPlugin):
    name = "my_fastapi_plugin"
    fastapi_apps = [
        {
            "name": "example_api",
            "app": my_app,
            "url_prefix": "/example"
        }
    ]

Operating System

Linux

Versions of Apache Airflow Providers

No response

Deployment

Other

Deployment details

No response

Anything else?

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[mandeepzemo]

I like to work on this, if open

[mandeepzemo]

@atul-astronomer Could you please confirm the expected behavior? The user should receive an error message when using the same plugin name. I have implemented the changes and shared the screenshot of the output below for your reference

File duplicate_plugin.py

from airflow.plugins_manager import AirflowPlugin
from fastapi import FastAPI

my_app = FastAPI()

@my_app.get("/ping")
async def ping():
    return {"message": "pong"}

class MyFastAPIPlugin(AirflowPlugin):
    name = "my_fastapi_plugin"
    fastapi_apps = [
        {
            "name": "example_api",
            "app": my_app,
            "url_prefix": "/example"
        }
    ]

@my_app.get("/hello")
async def ping():
    return {"message": "Hello"}

class MyFastAPIPlugin2(AirflowPlugin):
    name = "my_fastapi_plugin"
    fastapi_apps = [
        {
            "name": "example_api",
            "app": my_app,
            "url_prefix": "/example"
        }
    ]

Screenshot