List pipeline interrupts

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

import requests

url = "http://localhost:5173/api/flowdrop/pipelines/{pipelineId}/interrupts"

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/pipelines/{pipelineId}/interrupts', 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/pipelines/{pipelineId}/interrupts",
  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/pipelines/{pipelineId}/interrupts"

	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/pipelines/{pipelineId}/interrupts")

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",
      "nodeId": "<string>",
      "executionId": "<string>",
      "config": {
        "message": "Do you approve this action?",
        "confirm_label": "Approve",
        "cancel_label": "Reject"
      },
      "allowCancel": true,
      "messageId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
      "response": "<unknown>",
      "response_time": "2023-11-07T05:31:56Z",
      "user_id": "<string>",
      "createdAt": "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

pipelines

{pipelineId}

interrupts

List pipeline interrupts

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

import requests

url = "http://localhost:5173/api/flowdrop/pipelines/{pipelineId}/interrupts"

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/pipelines/{pipelineId}/interrupts', 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/pipelines/{pipelineId}/interrupts",
  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/pipelines/{pipelineId}/interrupts"

	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/pipelines/{pipelineId}/interrupts")

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",
      "nodeId": "<string>",
      "executionId": "<string>",
      "config": {
        "message": "Do you approve this action?",
        "confirm_label": "Approve",
        "cancel_label": "Reject"
      },
      "allowCancel": true,
      "messageId": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
      "response": "<unknown>",
      "response_time": "2023-11-07T05:31:56Z",
      "user_id": "<string>",
      "createdAt": "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

pipelineId

string<uuid>

required

Pipeline UUID

Query Parameters

status

enum<string>

Filter by interrupt status

Available options:

pending,

resolved,

cancelled

limit

integer

default:50

Maximum number of interrupts to return

Required range: 1 <= x <= 100

offset

integer

default:0

Number of interrupts to skip

Required range: x >= 0

Response

List of interrupts retrieved successfully

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 pipeline interrupts

Authorizations

Path Parameters

Query Parameters

Response