Arroyo Documentation home page
Search or ask...
Arroyo Cloud
Arroyo Cloud
Search...
Navigation
Pipelines
List all pipelines
Documentation
Github
Discord
API Reference
Releases
API Documentation
API Overview
Connectors
Connection Profiles
Connection Tables
Jobs
Pipelines
GET
List all pipelines
POST
Create a new pipeline
POST
Create a new preview pipeline
POST
Validate a query and return pipeline graph
GET
Get a single pipeline
DEL
Delete a pipeline
PATCH
Update a pipeline
GET
List a pipeline's jobs
POST
Restart a pipeline
UDFs
Pipelines
List all pipelines
GET
/
v1
/
pipelines
Send
Query
starting_after
string
string
null
starting_after
string
limit
integer
integer
null
limit
integer
Query Parameters
starting_after
string | null
limit
integer | null
Required range:
x > 0
Response
200 - application/json
data
object[]
required
Show child attributes
data.
action
enum<string>
Available options:
none
,
checkpoint
,
graceful
,
immediate
,
force
data.
actionInProgress
boolean
required
data.
actionText
string
required
data.
checkpointIntervalMicros
integer
required
Required range:
x > 0
data.
createdAt
integer
required
Required range:
x > 0
data.
graph
object
required
Show child attributes
data.graph.
edges
object[]
required
Show child attributes
data.graph.edges.
destId
integer
required
Required range:
x > 0
data.graph.edges.
edgeType
string
required
data.graph.edges.
keyType
string
required
data.graph.edges.
srcId
integer
required
Required range:
x > 0
data.graph.edges.
valueType
string
required
data.graph.
nodes
object[]
required
Show child attributes
data.graph.nodes.
description
string
required
data.graph.nodes.
nodeId
integer
required
Required range:
x > 0
data.graph.nodes.
operator
string
required
data.graph.nodes.
parallelism
integer
required
Required range:
x > 0
data.
id
string
required
data.
name
string
required
data.
preview
boolean
required
data.
query
string
required
data.
stop
enum<string>
required
Available options:
none
,
checkpoint
,
graceful
,
immediate
,
force
data.
udfs
object[]
required
Show child attributes
data.udfs.
definition
string
required
data.udfs.
language
enum<string>
Available options:
python
,
rust
hasMore
boolean
required
Subscribe to a job's output
Create a new pipeline
