List workflow pipelines

curl --request GET \
  --url http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines \
  --header 'Authorization: Bearer <token>'

import requests

url = "http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_PORT => "5173",
  CURLOPT_URL => "http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

	url := "http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

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

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

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines")

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

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

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

{
  "success": true,
  "data": [
    {
      "id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
      "workflow_id": "<string>",
      "status": "<string>",
      "created": "2023-11-07T05:31:56Z",
      "updated": "2023-11-07T05:31:56Z"
    }
  ],
  "message": "<string>",
  "error": "<string>"
}

{
  "success": false,
  "error": "Resource not found",
  "code": "NOT_FOUND"
}

{
  "success": false,
  "error": "Internal server error",
  "code": "INTERNAL_ERROR"
}

GET

workflow

{workflow_id}

pipelines

List workflow pipelines

curl --request GET \
  --url http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines \
  --header 'Authorization: Bearer <token>'

import requests

url = "http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines"

headers = {"Authorization": "Bearer <token>"}

response = requests.get(url, headers=headers)

print(response.text)

const options = {method: 'GET', headers: {Authorization: 'Bearer <token>'}};

fetch('http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_PORT => "5173",
  CURLOPT_URL => "http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "GET",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

	url := "http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines"

	req, _ := http.NewRequest("GET", url, nil)

	req.Header.Add("Authorization", "Bearer <token>")

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

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

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("http://localhost:5173/api/flowdrop/workflow/{workflow_id}/pipelines")

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

request = Net::HTTP::Get.new(url)
request["Authorization"] = 'Bearer <token>'

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

{
  "success": true,
  "data": [
    {
      "id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
      "workflow_id": "<string>",
      "status": "<string>",
      "created": "2023-11-07T05:31:56Z",
      "updated": "2023-11-07T05:31:56Z"
    }
  ],
  "message": "<string>",
  "error": "<string>"
}

{
  "success": false,
  "error": "Resource not found",
  "code": "NOT_FOUND"
}

{
  "success": false,
  "error": "Internal server error",
  "code": "INTERNAL_ERROR"
}

Authorizations

Authorization

string

header

required

JWT token for authentication

Path Parameters

workflow_id

string

required

Workflow ID or machine name

Query Parameters

status

enum<string>

Filter by pipeline status

Available options:

pending,

running,

completed,

failed,

cancelled

Response

List of pipeline executions

success

boolean

Whether the request was successful

data

object[]

Response data (type varies by endpoint)

Show child attributes

message

string

Response message

error

string

Error message (if any)

API documentation

Endpoints

List workflow pipelines

Authorizations

Path Parameters

Query Parameters

Response