Skip to content
Merged
Show file tree
Hide file tree
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
12 changes: 12 additions & 0 deletions airbyte/mcp/local.py
Comment thread
aaronsteers marked this conversation as resolved.
Comment thread
aaronsteers marked this conversation as resolved.
Original file line number Diff line number Diff line change
Expand Up @@ -122,6 +122,7 @@ def _get_mcp_source(
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
Comment thread
aaronsteers marked this conversation as resolved.
def validate_connector_config(
Expand Down Expand Up @@ -201,6 +202,7 @@ def validate_connector_config(
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
)
def list_connector_config_secrets(
connector_name: Annotated[
Expand Down Expand Up @@ -230,6 +232,7 @@ def list_connector_config_secrets(
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def list_dotenv_secrets() -> dict[str, list[str]]:
Expand All @@ -249,6 +252,7 @@ def list_dotenv_secrets() -> dict[str, list[str]]:
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def list_source_streams(
Expand Down Expand Up @@ -315,6 +319,7 @@ def list_source_streams(
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def get_source_stream_json_schema(
Expand Down Expand Up @@ -381,6 +386,7 @@ def get_source_stream_json_schema(

@mcp_tool(
read_only=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def read_source_stream_records(
Expand Down Expand Up @@ -471,6 +477,7 @@ def read_source_stream_records(

@mcp_tool(
read_only=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def get_stream_previews(
Expand Down Expand Up @@ -583,6 +590,7 @@ def get_stream_previews(

@mcp_tool(
destructive=False,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def sync_source_to_cache(
Expand Down Expand Up @@ -692,6 +700,7 @@ class CachedDatasetInfo(BaseModel):
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def list_cached_streams() -> list[CachedDatasetInfo]:
Expand All @@ -712,6 +721,7 @@ def list_cached_streams() -> list[CachedDatasetInfo]:
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def describe_default_cache() -> dict[str, Any]:
Expand Down Expand Up @@ -763,6 +773,7 @@ def _is_safe_sql(sql_query: str) -> bool:
@mcp_tool(
read_only=True,
idempotent=True,
requires_client_filesystem=True,
extra_help_text=_CONFIG_HELP,
)
def run_sql_query(
Expand Down Expand Up @@ -820,6 +831,7 @@ def run_sql_query(

@mcp_tool(
destructive=True,
requires_client_filesystem=True,
)
def destination_smoke_test( # noqa: PLR0913, PLR0917
destination_connector_name: Annotated[
Expand Down
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ dependencies = [
"typing-extensions",
"uuid7>=0.1.0,<1.0",
"fastmcp>=3.0,<4.0",
"fastmcp-extensions>=0.5.0,<1.0.0",
"fastmcp-extensions>=0.7.0,<1.0.0",
"starlette",
"uv>=0.5.0,<0.9.0",
"prefab-ui>=0.20.1,<0.21",
Expand Down
40 changes: 36 additions & 4 deletions uv.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading