Nodes API

Test Python Node

POST /python/test
Content-Type: application/json

Request

{
  "code": "def transform(df):\n    return df[df['amount'] > 100]",
  "input_data": [
    {"id": 1, "amount": 50},
    {"id": 2, "amount": 150},
    {"id": 3, "amount": 200}
  ],
  "function_name": "transform"
}

Response

{
  "data": {
    "success": true,
    "output_data": [
      {"id": 2, "amount": 150},
      {"id": 3, "amount": 200}
    ],
    "output_rows": 2,
    "execution_time_ms": 45.2
  }
}

Test SQL Node

POST /sql/test
Content-Type: application/json

Request

{
  "query": "SELECT * FROM input WHERE amount > 100",
  "input_data": [
    {"id": 1, "amount": 50},
    {"id": 2, "amount": 150}
  ]
}

Test REST Node

POST /rest/test
Content-Type: application/json

Request

{
  "url": "https://api.example.com/data",
  "method": "GET",
  "headers": {
    "Authorization": "Bearer token"
  }
}

Response

{
  "data": {
    "success": true,
    "status_code": 200,
    "response_data": [...],
    "execution_time_ms": 234.5
  }
}

Test DBT Node

POST /dbt/test
Content-Type: application/json

Request

{
  "project_path": "/path/to/dbt/project",
  "model_name": "my_model",
  "vars": {
    "target": "prod"
  }
}

Node Types Reference

Type	Test Endpoint	Description
source	N/A	Data source
python	/python/test	Custom Python code
sql	/sql/test	DuckDB SQL
filter	/sql/test	Row filtering
reduce	/sql/test	Aggregations
rest	/rest/test	REST API calls
database	/sql/test	Database queries
dbt	/dbt/test	DBT models