DalgoT4D/dalgo-mcp

tools

• dalgo_acquire_canvas_lock

  Acquire a lock on the transform canvas. Required before making any canvas modifications

• dalgo_add_source_to_canvas

  Add an existing source or model to the canvas as a node

• dalgo_create_chart

  Create a new chart

• dalgo_create_dashboard

  Create a new dashboard

• dalgo_create_operation

  Create a new operation node on the canvas (join, filter, rename, aggregate, etc.)

• dalgo_create_pipeline

  Create a new orchestration pipeline

• dalgo_create_report

  Create a new report (data snapshot)

• dalgo_delete_chart

  Delete a chart

• dalgo_delete_dashboard

  Delete a dashboard

• dalgo_delete_pipeline

  Delete a pipeline by its deployment ID

• dalgo_delete_report

  Delete a report

• dalgo_delete_source

  Delete a data source

• dalgo_edit_operation

  Edit an existing operation node on the canvas

• dalgo_get_chart

  Get details of a specific chart

• dalgo_get_chart_data

  Execute a chart's query and return the resulting data

• dalgo_get_connection

  Get details of a specific Airbyte connection

• dalgo_get_connection_catalog

  Get the stream catalog for an Airbyte connection (selected streams and sync modes)

• dalgo_get_current_user

  Get the currently authenticated Dalgo user's profile information

• dalgo_get_dashboard

  Get details of a specific dashboard including its charts

• dalgo_get_data_types

  Get the list of warehouse-specific data types (used for cast operations)

• dalgo_get_dbt_workspace

  Get the dbt workspace configuration for the organization

• dalgo_get_doc

  Fetch and return the full content of a Dalgo documentation page

• dalgo_get_feature_flags

  Get feature flags enabled for the current Dalgo organization

• dalgo_get_flow_run

  Get details of a specific flow run

• dalgo_get_flow_run_logs

  Get logs for a specific flow run. Large logs are truncated to avoid context overflow —

• dalgo_get_git_status

  Get the git status of the dbt project repository (modified/untracked files)

• dalgo_get_node_columns

  Get column names and data types for a specific canvas node

• dalgo_get_node_details

  Get full details of a canvas node including its operation config and input nodes

• dalgo_get_pipeline

  Get details of a specific pipeline by its deployment ID

• dalgo_get_pipeline_run_history

  Get the run history for a specific pipeline

• dalgo_get_report

  View a specific report's data

• dalgo_get_source

  Get details of a specific data source

• dalgo_get_sources_models

  Get all available sources and models with their columns

• dalgo_get_sync_history

  Get sync run history for an Airbyte connection

• dalgo_get_table_columns

  Get column names and types for a specific warehouse table

• dalgo_get_table_data

  Fetch rows from a warehouse table. Defaults to 10 rows to avoid context overflow

• dalgo_get_table_row_count

  Get the total row count of a warehouse table

• dalgo_get_transform_graph

  Get the dbt project DAG (directed acyclic graph) showing model dependencies

• dalgo_get_unread_count

  Get the count of unread notifications

• dalgo_list_charts

  List all charts in the organization

• dalgo_list_connections

  List all Airbyte connections (source-to-destination syncs) in the organization

• dalgo_list_dashboards

  List all dashboards in the organization

• dalgo_list_notifications

  List recent notifications for the current user

• dalgo_list_org_users

  List all users in the current Dalgo organization

• dalgo_list_pipelines

  List all orchestration pipelines (Prefect deployments) in the organization

• dalgo_list_reports

  List all saved reports (data snapshots) in the organization

• dalgo_list_schemas

  List all schemas in the connected data warehouse

• dalgo_list_source_definitions

  List all available Airbyte source definitions (connector types)

• dalgo_list_sources

  List all configured data sources (Airbyte sources) in the organization

• dalgo_list_tables

  List all tables in a specific warehouse schema

• dalgo_mark_notifications_read

  Mark notifications as read

• dalgo_publish_changes

  Commit and push dbt project changes to git

• dalgo_release_canvas_lock

  Release the lock on the transform canvas after modifications are complete

• dalgo_run_dbt

  Trigger a dbt run via Celery (async task). Optionally pass command and flags

• dalgo_sync_sources

  Sync dbt sources from the connected warehouse, updating the dbt project's source definitions

• dalgo_terminate_chain

  Materialize an operation chain into a dbt model

• dalgo_trigger_pipeline_run

  Trigger an immediate run of a pipeline

• dalgo_update_chart

  Update an existing chart

• dalgo_update_dashboard

  Update an existing dashboard

• dalgo_update_pipeline

  Update an existing pipeline's configuration