KosmoKrator

automation

Pipedream Lua API for KosmoKrator Agents

Agent-facing Lua documentation and function reference for the Pipedream KosmoKrator integration.

7 functions 7 read 0 write Bearer token auth

Lua Namespace

Agents call this integration through app.integrations.pipedream.*. Use lua_read_doc("integrations.pipedream") inside KosmoKrator to discover the same reference at runtime.

Agent-Facing Lua Docs

This is the rendered version of the full Lua documentation exposed to agents when they inspect the integration namespace.

Pipedream — Lua API Reference

list_workflows

List automation workflows in Pipedream.

Parameters

NameTypeRequiredDescription
pageintegernoPage number for pagination (default: 1)
limitintegernoNumber of workflows per page (default: 25, max: 100)

Examples

local result = app.integrations.pipedream.list_workflows({
  page = 1,
  limit = 10
})

for _, wf in ipairs(result.data) do
  print(wf.id .. ": " .. wf.name)
end

get_workflow

Get details of a specific workflow by ID.

Parameters

NameTypeRequiredDescription
idstringyesThe workflow ID

Examples

local result = app.integrations.pipedream.get_workflow({
  id = "abc_123"
})

print(result.data.name)
print("Status: " .. result.data.status)

list_components

List available Pipedream components (actions, triggers, etc.).

Parameters

NameTypeRequiredDescription
typestringnoComponent type filter: “action”, “trigger”
limitintegernoNumber of components per page (default: 25, max: 100)

Examples

-- List action components
local result = app.integrations.pipedream.list_components({
  type = "action",
  limit = 20
})

for _, comp in ipairs(result.data) do
  print(comp.key .. " (" .. comp.app .. ")")
end

get_component

Get details of a specific component by app and key.

Parameters

NameTypeRequiredDescription
appstringyesApp slug (e.g., “slack”, “github”)
idstringyesComponent key or ID (e.g., “send-message”)

Examples

local result = app.integrations.pipedream.get_component({
  app = "slack",
  id = "send-message"
})

print(result.data.name)
print("Version: " .. result.data.version)

list_connected_accounts

List connected third-party accounts.

Parameters

NameTypeRequiredDescription
pageintegernoPage number for pagination (default: 1)
limitintegernoNumber of accounts per page (default: 25, max: 100)

Examples

local result = app.integrations.pipedream.list_connected_accounts({
  page = 1,
  limit = 10
})

for _, acct in ipairs(result.data) do
  print(acct.id .. ": " .. acct.name .. " (" .. acct.app .. ")")
end

list_triggers

List event triggers for a specific workflow.

Parameters

NameTypeRequiredDescription
workflow_idstringyesThe workflow ID to list triggers for

Examples

local result = app.integrations.pipedream.list_triggers({
  workflow_id = "abc_123"
})

for _, trigger in ipairs(result.data) do
  print(trigger.type .. ": " .. (trigger.name or "unnamed"))
end

get_current_user

Get the currently authenticated user profile.

Parameters

None.

Examples

local result = app.integrations.pipedream.get_current_user({})

print("User: " .. result.data.name)
print("Email: " .. result.data.email)

Multi-Account Usage

If you have multiple Pipedream accounts configured, use account-specific namespaces:

-- Default account (always works)
app.integrations.pipedream.list_workflows({})

-- Explicit default (portable across setups)
app.integrations.pipedream.default.list_workflows({})

-- Named accounts
app.integrations.pipedream.production.list_workflows({})
app.integrations.pipedream.staging.list_workflows({})

All functions are identical across accounts — only the credentials differ.

Raw agent markdown
# Pipedream — Lua API Reference

## list_workflows

List automation workflows in Pipedream.

### Parameters

| Name | Type | Required | Description |
|------|------|----------|-------------|
| `page` | integer | no | Page number for pagination (default: 1) |
| `limit` | integer | no | Number of workflows per page (default: 25, max: 100) |

### Examples

```lua
local result = app.integrations.pipedream.list_workflows({
  page = 1,
  limit = 10
})

for _, wf in ipairs(result.data) do
  print(wf.id .. ": " .. wf.name)
end
```

---

## get_workflow

Get details of a specific workflow by ID.

### Parameters

| Name | Type | Required | Description |
|------|------|----------|-------------|
| `id` | string | yes | The workflow ID |

### Examples

```lua
local result = app.integrations.pipedream.get_workflow({
  id = "abc_123"
})

print(result.data.name)
print("Status: " .. result.data.status)
```

---

## list_components

List available Pipedream components (actions, triggers, etc.).

### Parameters

| Name | Type | Required | Description |
|------|------|----------|-------------|
| `type` | string | no | Component type filter: "action", "trigger" |
| `limit` | integer | no | Number of components per page (default: 25, max: 100) |

### Examples

```lua
-- List action components
local result = app.integrations.pipedream.list_components({
  type = "action",
  limit = 20
})

for _, comp in ipairs(result.data) do
  print(comp.key .. " (" .. comp.app .. ")")
end
```

---

## get_component

Get details of a specific component by app and key.

### Parameters

| Name | Type | Required | Description |
|------|------|----------|-------------|
| `app` | string | yes | App slug (e.g., "slack", "github") |
| `id` | string | yes | Component key or ID (e.g., "send-message") |

### Examples

```lua
local result = app.integrations.pipedream.get_component({
  app = "slack",
  id = "send-message"
})

print(result.data.name)
print("Version: " .. result.data.version)
```

---

## list_connected_accounts

List connected third-party accounts.

### Parameters

| Name | Type | Required | Description |
|------|------|----------|-------------|
| `page` | integer | no | Page number for pagination (default: 1) |
| `limit` | integer | no | Number of accounts per page (default: 25, max: 100) |

### Examples

```lua
local result = app.integrations.pipedream.list_connected_accounts({
  page = 1,
  limit = 10
})

for _, acct in ipairs(result.data) do
  print(acct.id .. ": " .. acct.name .. " (" .. acct.app .. ")")
end
```

---

## list_triggers

List event triggers for a specific workflow.

### Parameters

| Name | Type | Required | Description |
|------|------|----------|-------------|
| `workflow_id` | string | yes | The workflow ID to list triggers for |

### Examples

```lua
local result = app.integrations.pipedream.list_triggers({
  workflow_id = "abc_123"
})

for _, trigger in ipairs(result.data) do
  print(trigger.type .. ": " .. (trigger.name or "unnamed"))
end
```

---

## get_current_user

Get the currently authenticated user profile.

### Parameters

None.

### Examples

```lua
local result = app.integrations.pipedream.get_current_user({})

print("User: " .. result.data.name)
print("Email: " .. result.data.email)
```

---

## Multi-Account Usage

If you have multiple Pipedream accounts configured, use account-specific namespaces:

```lua
-- Default account (always works)
app.integrations.pipedream.list_workflows({})

-- Explicit default (portable across setups)
app.integrations.pipedream.default.list_workflows({})

-- Named accounts
app.integrations.pipedream.production.list_workflows({})
app.integrations.pipedream.staging.list_workflows({})
```

All functions are identical across accounts — only the credentials differ.

Metadata-Derived Lua Example

local result = app.integrations.pipedream.pipedream_list_workflows({
  page = 1,
  limit = 1
})
print(result)

Functions

pipedream_list_workflows

List automation workflows in Pipedream. Returns a paginated list of workflows with their IDs, names, and statuses.

Operation
Read read
Full name
pipedream.pipedream_list_workflows
ParameterTypeRequiredDescription
page integer no Page number for pagination (default: 1).
limit integer no Number of workflows to return per page (default: 25, max: 100).

pipedream_get_workflow

Get details of a specific Pipedream workflow by ID, including its configuration, steps, and current status.

Operation
Read read
Full name
pipedream.pipedream_get_workflow
ParameterTypeRequiredDescription
id string yes The workflow ID.

pipedream_list_components

List available Pipedream components (actions, triggers, etc.). Components are reusable building blocks for connecting to third-party APIs.

Operation
Read read
Full name
pipedream.pipedream_list_components
ParameterTypeRequiredDescription
type string no Component type filter. Common values: "action", "trigger". Omit to list all types.
limit integer no Number of components to return per page (default: 25, max: 100).

pipedream_get_component

Get details of a specific Pipedream component by app and component key. Returns the component configuration, props, and version info.

Operation
Read read
Full name
pipedream.pipedream_get_component
ParameterTypeRequiredDescription
app string yes The app slug (e.g., "slack", "github", "google_sheets").
id string yes The component key or ID (e.g., "send-message").

pipedream_list_connected_accounts

List connected third-party accounts in Pipedream. These are the OAuth-connected accounts used by workflows to interact with external services.

Operation
Read read
Full name
pipedream.pipedream_list_connected_accounts
ParameterTypeRequiredDescription
page integer no Page number for pagination (default: 1).
limit integer no Number of accounts to return per page (default: 25, max: 100).

pipedream_list_triggers

List event triggers for a specific Pipedream workflow. Triggers define the events that cause a workflow to run.

Operation
Read read
Full name
pipedream.pipedream_list_triggers
ParameterTypeRequiredDescription
workflow_id string yes The workflow ID to list triggers for.

pipedream_get_current_user

Get the currently authenticated Pipedream user profile, including name, email, and workspace details.

Operation
Read read
Full name
pipedream.pipedream_get_current_user
ParameterTypeRequiredDescription
No parameters.