dlt._workspace.mcp.tools.pipeline
available_pipelines
def available_pipelines() -> list[str]
List all available dlt pipelines. Each pipeline has several tables.
available_tables
def available_tables(pipeline_name: str) -> dict[str, Any]
List all available tables in the specified pipeline.
table_preview
def table_preview(pipeline_name: str, table_name: str) -> dict[str, Any]
Get the first row from the specified table.
table_schema
def table_schema(pipeline_name: str, table_name: str) -> dict[str, Any]
Get the schema of the specified table.
execute_sql_query
def execute_sql_query(pipeline_name: str, sql_select_query: str) -> str
Executes SELECT SQL statement for simple data analysis.
Use the table_schema() tool to get the available columns and use their fully qualified name in the SQL query.