Declares what happens when new rows land in a dataset: invoke an action on

curl --request PUT \
  --url https://api.erdo.ai/v1/dataset-row-actions \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "dataset": "<string>",
  "destination": {
    "columns": {},
    "dataset": "<string>",
    "key_column": "<string>"
  },
  "enabled": true,
  "key_column": "<string>",
  "name": "<string>",
  "on_update": "<string>",
  "steps": [
    {
      "app": "<string>",
      "fallback": true,
      "for_each": {},
      "found_when": "<string>",
      "input": {},
      "key": "<string>",
      "result_path": "<string>",
      "script": "<string>"
    }
  ],
  "timestamp_column": "<string>"
}
'

import requests

url = "https://api.erdo.ai/v1/dataset-row-actions"

payload = {
    "dataset": "<string>",
    "destination": {
        "columns": {},
        "dataset": "<string>",
        "key_column": "<string>"
    },
    "enabled": True,
    "key_column": "<string>",
    "name": "<string>",
    "on_update": "<string>",
    "steps": [
        {
            "app": "<string>",
            "fallback": True,
            "for_each": {},
            "found_when": "<string>",
            "input": {},
            "key": "<string>",
            "result_path": "<string>",
            "script": "<string>"
        }
    ],
    "timestamp_column": "<string>"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.put(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'PUT',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    dataset: '<string>',
    destination: {columns: {}, dataset: '<string>', key_column: '<string>'},
    enabled: true,
    key_column: '<string>',
    name: '<string>',
    on_update: '<string>',
    steps: [
      {
        app: '<string>',
        fallback: true,
        for_each: {},
        found_when: '<string>',
        input: {},
        key: '<string>',
        result_path: '<string>',
        script: '<string>'
      }
    ],
    timestamp_column: '<string>'
  })
};

fetch('https://api.erdo.ai/v1/dataset-row-actions', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.erdo.ai/v1/dataset-row-actions",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "PUT",
  CURLOPT_POSTFIELDS => json_encode([
    'dataset' => '<string>',
    'destination' => [
        'columns' => [
                
        ],
        'dataset' => '<string>',
        'key_column' => '<string>'
    ],
    'enabled' => true,
    'key_column' => '<string>',
    'name' => '<string>',
    'on_update' => '<string>',
    'steps' => [
        [
                'app' => '<string>',
                'fallback' => true,
                'for_each' => [
                                
                ],
                'found_when' => '<string>',
                'input' => [
                                
                ],
                'key' => '<string>',
                'result_path' => '<string>',
                'script' => '<string>'
        ]
    ],
    'timestamp_column' => '<string>'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api.erdo.ai/v1/dataset-row-actions"

	payload := strings.NewReader("{\n  \"dataset\": \"<string>\",\n  \"destination\": {\n    \"columns\": {},\n    \"dataset\": \"<string>\",\n    \"key_column\": \"<string>\"\n  },\n  \"enabled\": true,\n  \"key_column\": \"<string>\",\n  \"name\": \"<string>\",\n  \"on_update\": \"<string>\",\n  \"steps\": [\n    {\n      \"app\": \"<string>\",\n      \"fallback\": true,\n      \"for_each\": {},\n      \"found_when\": \"<string>\",\n      \"input\": {},\n      \"key\": \"<string>\",\n      \"result_path\": \"<string>\",\n      \"script\": \"<string>\"\n    }\n  ],\n  \"timestamp_column\": \"<string>\"\n}")

	req, _ := http.NewRequest("PUT", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.put("https://api.erdo.ai/v1/dataset-row-actions")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"dataset\": \"<string>\",\n  \"destination\": {\n    \"columns\": {},\n    \"dataset\": \"<string>\",\n    \"key_column\": \"<string>\"\n  },\n  \"enabled\": true,\n  \"key_column\": \"<string>\",\n  \"name\": \"<string>\",\n  \"on_update\": \"<string>\",\n  \"steps\": [\n    {\n      \"app\": \"<string>\",\n      \"fallback\": true,\n      \"for_each\": {},\n      \"found_when\": \"<string>\",\n      \"input\": {},\n      \"key\": \"<string>\",\n      \"result_path\": \"<string>\",\n      \"script\": \"<string>\"\n    }\n  ],\n  \"timestamp_column\": \"<string>\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.erdo.ai/v1/dataset-row-actions")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Put.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"dataset\": \"<string>\",\n  \"destination\": {\n    \"columns\": {},\n    \"dataset\": \"<string>\",\n    \"key_column\": \"<string>\"\n  },\n  \"enabled\": true,\n  \"key_column\": \"<string>\",\n  \"name\": \"<string>\",\n  \"on_update\": \"<string>\",\n  \"steps\": [\n    {\n      \"app\": \"<string>\",\n      \"fallback\": true,\n      \"for_each\": {},\n      \"found_when\": \"<string>\",\n      \"input\": {},\n      \"key\": \"<string>\",\n      \"result_path\": \"<string>\",\n      \"script\": \"<string>\"\n    }\n  ],\n  \"timestamp_column\": \"<string>\"\n}"

response = http.request(request)
puts response.read_body

{
  "dataset": "<string>",
  "destination": {
    "columns": {},
    "dataset": "<string>",
    "key_column": "<string>"
  },
  "enabled": true,
  "job_id": "<string>",
  "key_column": "<string>",
  "name": "<string>",
  "on_update": "<string>",
  "steps": [
    {
      "app": "<string>",
      "fallback": true,
      "for_each": {},
      "found_when": "<string>",
      "input": {},
      "key": "<string>",
      "result_path": "<string>",
      "script": "<string>"
    }
  ],
  "timestamp_column": "<string>"
}

{
  "code": "not_found",
  "details": {},
  "message": "<string>"
}

PUT

dataset-row-actions

Declares what happens when new rows land in a dataset: invoke an action on

curl --request PUT \
  --url https://api.erdo.ai/v1/dataset-row-actions \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "dataset": "<string>",
  "destination": {
    "columns": {},
    "dataset": "<string>",
    "key_column": "<string>"
  },
  "enabled": true,
  "key_column": "<string>",
  "name": "<string>",
  "on_update": "<string>",
  "steps": [
    {
      "app": "<string>",
      "fallback": true,
      "for_each": {},
      "found_when": "<string>",
      "input": {},
      "key": "<string>",
      "result_path": "<string>",
      "script": "<string>"
    }
  ],
  "timestamp_column": "<string>"
}
'

import requests

url = "https://api.erdo.ai/v1/dataset-row-actions"

payload = {
    "dataset": "<string>",
    "destination": {
        "columns": {},
        "dataset": "<string>",
        "key_column": "<string>"
    },
    "enabled": True,
    "key_column": "<string>",
    "name": "<string>",
    "on_update": "<string>",
    "steps": [
        {
            "app": "<string>",
            "fallback": True,
            "for_each": {},
            "found_when": "<string>",
            "input": {},
            "key": "<string>",
            "result_path": "<string>",
            "script": "<string>"
        }
    ],
    "timestamp_column": "<string>"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.put(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'PUT',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    dataset: '<string>',
    destination: {columns: {}, dataset: '<string>', key_column: '<string>'},
    enabled: true,
    key_column: '<string>',
    name: '<string>',
    on_update: '<string>',
    steps: [
      {
        app: '<string>',
        fallback: true,
        for_each: {},
        found_when: '<string>',
        input: {},
        key: '<string>',
        result_path: '<string>',
        script: '<string>'
      }
    ],
    timestamp_column: '<string>'
  })
};

fetch('https://api.erdo.ai/v1/dataset-row-actions', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api.erdo.ai/v1/dataset-row-actions",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "PUT",
  CURLOPT_POSTFIELDS => json_encode([
    'dataset' => '<string>',
    'destination' => [
        'columns' => [
                
        ],
        'dataset' => '<string>',
        'key_column' => '<string>'
    ],
    'enabled' => true,
    'key_column' => '<string>',
    'name' => '<string>',
    'on_update' => '<string>',
    'steps' => [
        [
                'app' => '<string>',
                'fallback' => true,
                'for_each' => [
                                
                ],
                'found_when' => '<string>',
                'input' => [
                                
                ],
                'key' => '<string>',
                'result_path' => '<string>',
                'script' => '<string>'
        ]
    ],
    'timestamp_column' => '<string>'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api.erdo.ai/v1/dataset-row-actions"

	payload := strings.NewReader("{\n  \"dataset\": \"<string>\",\n  \"destination\": {\n    \"columns\": {},\n    \"dataset\": \"<string>\",\n    \"key_column\": \"<string>\"\n  },\n  \"enabled\": true,\n  \"key_column\": \"<string>\",\n  \"name\": \"<string>\",\n  \"on_update\": \"<string>\",\n  \"steps\": [\n    {\n      \"app\": \"<string>\",\n      \"fallback\": true,\n      \"for_each\": {},\n      \"found_when\": \"<string>\",\n      \"input\": {},\n      \"key\": \"<string>\",\n      \"result_path\": \"<string>\",\n      \"script\": \"<string>\"\n    }\n  ],\n  \"timestamp_column\": \"<string>\"\n}")

	req, _ := http.NewRequest("PUT", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.put("https://api.erdo.ai/v1/dataset-row-actions")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"dataset\": \"<string>\",\n  \"destination\": {\n    \"columns\": {},\n    \"dataset\": \"<string>\",\n    \"key_column\": \"<string>\"\n  },\n  \"enabled\": true,\n  \"key_column\": \"<string>\",\n  \"name\": \"<string>\",\n  \"on_update\": \"<string>\",\n  \"steps\": [\n    {\n      \"app\": \"<string>\",\n      \"fallback\": true,\n      \"for_each\": {},\n      \"found_when\": \"<string>\",\n      \"input\": {},\n      \"key\": \"<string>\",\n      \"result_path\": \"<string>\",\n      \"script\": \"<string>\"\n    }\n  ],\n  \"timestamp_column\": \"<string>\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api.erdo.ai/v1/dataset-row-actions")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Put.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"dataset\": \"<string>\",\n  \"destination\": {\n    \"columns\": {},\n    \"dataset\": \"<string>\",\n    \"key_column\": \"<string>\"\n  },\n  \"enabled\": true,\n  \"key_column\": \"<string>\",\n  \"name\": \"<string>\",\n  \"on_update\": \"<string>\",\n  \"steps\": [\n    {\n      \"app\": \"<string>\",\n      \"fallback\": true,\n      \"for_each\": {},\n      \"found_when\": \"<string>\",\n      \"input\": {},\n      \"key\": \"<string>\",\n      \"result_path\": \"<string>\",\n      \"script\": \"<string>\"\n    }\n  ],\n  \"timestamp_column\": \"<string>\"\n}"

response = http.request(request)
puts response.read_body

{
  "dataset": "<string>",
  "destination": {
    "columns": {},
    "dataset": "<string>",
    "key_column": "<string>"
  },
  "enabled": true,
  "job_id": "<string>",
  "key_column": "<string>",
  "name": "<string>",
  "on_update": "<string>",
  "steps": [
    {
      "app": "<string>",
      "fallback": true,
      "for_each": {},
      "found_when": "<string>",
      "input": {},
      "key": "<string>",
      "result_path": "<string>",
      "script": "<string>"
    }
  ],
  "timestamp_column": "<string>"
}

{
  "code": "not_found",
  "details": {},
  "message": "<string>"
}

Authorizations

Authorization

string

header

required

An Erdo API key (erdo_api_...) or scoped token (erdo_token_...).

Body

application/json

dataset

string

including ones created later.

destination

Where to record what the steps returned. Omitting a destination entirely is · object

normal: a step that sends an email or files a ticket has done its work by running, and has nothing to store.

Show child attributes

enabled

boolean

than pausing it, so declaring it again later starts from the rows arriving then instead of working through everything that accumulated in between.

key_column

string

this dataset upserts on. It is how a row being written a second time is recognised as the same row rather than a new one. Normally detected; set it when the dataset identifies a row unconventionally.

name

string

dataset can both alert a desk and enrich a record without either replacing the other. Lowercase letters, digits, hyphens and underscores.

on_update

string

written again: "skip" (the default) leaves it alone, and "act" takes it through the steps again. Default to skip unless a later write genuinely changes the answer — acting again invokes the actions again, and pays for them again.

steps

One step of a declaration. A step is EITHER an action to invoke (app and key) · object[]

once an earlier action has answered, and a script always runs. A step whose templated input resolves to nothing cannot be built for that row, so the next one is tried instead.

Show child attributes

timestamp_column

string

detected; set it when the dataset names that column unconventionally.

Response

Success response

dataset

string

destination

Where to record what the steps returned. Omitting a destination entirely is · object

normal: a step that sends an email or files a ticket has done its work by running, and has nothing to store.

Show child attributes

enabled

boolean

job_id

string

history can be inspected through the automation surfaces.

key_column

string

name

string

on_update

string

steps

One step of a declaration. A step is EITHER an action to invoke (app and key) · object[]

Show child attributes

timestamp_column

string

Lists what already happens to new rows in a dataset: every declaration on it, ListDatasetsAPI mirrors the erdo_list_datasets MCP tool as a REST endpoint.

Platform API

API Reference

Build apps

Python SDK

TypeScript SDK

Declares what happens when new rows land in a dataset: invoke an action on

Authorizations

Body

Response