Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions airbyte/mcp/_connector_registry.py
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
from fastmcp import FastMCP
from pydantic import BaseModel, Field

from airbyte._executors.util import DEFAULT_MANIFEST_URL
from airbyte._util.meta import is_docker_installed
from airbyte.sources import get_available_connectors
from airbyte.sources.registry import ConnectorMetadata, get_connector_metadata
Expand Down Expand Up @@ -89,6 +90,7 @@ class ConnectorInfo(BaseModel):
connector_metadata: ConnectorMetadata | None = None
documentation_url: str | None = None
config_spec_jsonschema: dict | None = None
manifest_url: str | None = None


def get_connector_info(
Expand Down Expand Up @@ -117,11 +119,17 @@ def get_connector_info(
connector.install()
config_spec_jsonschema = connector.config_spec

manifest_url = DEFAULT_MANIFEST_URL.format(
source_name=connector_name,
version="latest",
)

return ConnectorInfo(
connector_name=connector.name,
connector_metadata=connector_metadata,
documentation_url=connector.docs_url,
config_spec_jsonschema=config_spec_jsonschema,
manifest_url=manifest_url,
)


Expand Down
Loading