Read Work Pools
curl --request POST \
--url https://api.example.com/work_pools/filter \
--header 'Content-Type: application/json' \
--data '
{
"work_pools": {
"operator": "and_",
"id": {
"any_": [
"3c90c3cc-0d44-4b50-8888-8dd25736052a"
]
},
"name": {
"any_": [
"<string>"
]
},
"type": {
"any_": [
"<string>"
]
}
},
"offset": 0,
"limit": 123
}
'import requests
url = "https://api.example.com/work_pools/filter"
payload = {
"work_pools": {
"operator": "and_",
"id": { "any_": ["3c90c3cc-0d44-4b50-8888-8dd25736052a"] },
"name": { "any_": ["<string>"] },
"type": { "any_": ["<string>"] }
},
"offset": 0,
"limit": 123
}
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({
work_pools: {
operator: 'and_',
id: {any_: ['3c90c3cc-0d44-4b50-8888-8dd25736052a']},
name: {any_: ['<string>']},
type: {any_: ['<string>']}
},
offset: 0,
limit: 123
})
};
fetch('https://api.example.com/work_pools/filter', 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.example.com/work_pools/filter",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'work_pools' => [
'operator' => 'and_',
'id' => [
'any_' => [
'3c90c3cc-0d44-4b50-8888-8dd25736052a'
]
],
'name' => [
'any_' => [
'<string>'
]
],
'type' => [
'any_' => [
'<string>'
]
]
],
'offset' => 0,
'limit' => 123
]),
CURLOPT_HTTPHEADER => [
"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.example.com/work_pools/filter"
payload := strings.NewReader("{\n \"work_pools\": {\n \"operator\": \"and_\",\n \"id\": {\n \"any_\": [\n \"3c90c3cc-0d44-4b50-8888-8dd25736052a\"\n ]\n },\n \"name\": {\n \"any_\": [\n \"<string>\"\n ]\n },\n \"type\": {\n \"any_\": [\n \"<string>\"\n ]\n }\n },\n \"offset\": 0,\n \"limit\": 123\n}")
req, _ := http.NewRequest("POST", url, payload)
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.post("https://api.example.com/work_pools/filter")
.header("Content-Type", "application/json")
.body("{\n \"work_pools\": {\n \"operator\": \"and_\",\n \"id\": {\n \"any_\": [\n \"3c90c3cc-0d44-4b50-8888-8dd25736052a\"\n ]\n },\n \"name\": {\n \"any_\": [\n \"<string>\"\n ]\n },\n \"type\": {\n \"any_\": [\n \"<string>\"\n ]\n }\n },\n \"offset\": 0,\n \"limit\": 123\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/work_pools/filter")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"work_pools\": {\n \"operator\": \"and_\",\n \"id\": {\n \"any_\": [\n \"3c90c3cc-0d44-4b50-8888-8dd25736052a\"\n ]\n },\n \"name\": {\n \"any_\": [\n \"<string>\"\n ]\n },\n \"type\": {\n \"any_\": [\n \"<string>\"\n ]\n }\n },\n \"offset\": 0,\n \"limit\": 123\n}"
response = http.request(request)
puts response.read_body[
{
"id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"created": "2023-11-07T05:31:56Z",
"updated": "2023-11-07T05:31:56Z",
"name": "<string>",
"type": "<string>",
"description": "<string>",
"base_job_template": {},
"is_paused": false,
"concurrency_limit": 1,
"default_queue_id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"storage_configuration": {
"bundle_upload_step": {},
"bundle_execution_step": {},
"default_result_storage_block_id": "3c90c3cc-0d44-4b50-8888-8dd25736052a"
},
"active_slots": 123
}
]{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>",
"input": "<unknown>",
"ctx": {}
}
]
}Work Pools
Read Work Pools
Read multiple work pools
POST
/
work_pools
/
filter
Read Work Pools
curl --request POST \
--url https://api.example.com/work_pools/filter \
--header 'Content-Type: application/json' \
--data '
{
"work_pools": {
"operator": "and_",
"id": {
"any_": [
"3c90c3cc-0d44-4b50-8888-8dd25736052a"
]
},
"name": {
"any_": [
"<string>"
]
},
"type": {
"any_": [
"<string>"
]
}
},
"offset": 0,
"limit": 123
}
'import requests
url = "https://api.example.com/work_pools/filter"
payload = {
"work_pools": {
"operator": "and_",
"id": { "any_": ["3c90c3cc-0d44-4b50-8888-8dd25736052a"] },
"name": { "any_": ["<string>"] },
"type": { "any_": ["<string>"] }
},
"offset": 0,
"limit": 123
}
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({
work_pools: {
operator: 'and_',
id: {any_: ['3c90c3cc-0d44-4b50-8888-8dd25736052a']},
name: {any_: ['<string>']},
type: {any_: ['<string>']}
},
offset: 0,
limit: 123
})
};
fetch('https://api.example.com/work_pools/filter', 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.example.com/work_pools/filter",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'work_pools' => [
'operator' => 'and_',
'id' => [
'any_' => [
'3c90c3cc-0d44-4b50-8888-8dd25736052a'
]
],
'name' => [
'any_' => [
'<string>'
]
],
'type' => [
'any_' => [
'<string>'
]
]
],
'offset' => 0,
'limit' => 123
]),
CURLOPT_HTTPHEADER => [
"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.example.com/work_pools/filter"
payload := strings.NewReader("{\n \"work_pools\": {\n \"operator\": \"and_\",\n \"id\": {\n \"any_\": [\n \"3c90c3cc-0d44-4b50-8888-8dd25736052a\"\n ]\n },\n \"name\": {\n \"any_\": [\n \"<string>\"\n ]\n },\n \"type\": {\n \"any_\": [\n \"<string>\"\n ]\n }\n },\n \"offset\": 0,\n \"limit\": 123\n}")
req, _ := http.NewRequest("POST", url, payload)
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.post("https://api.example.com/work_pools/filter")
.header("Content-Type", "application/json")
.body("{\n \"work_pools\": {\n \"operator\": \"and_\",\n \"id\": {\n \"any_\": [\n \"3c90c3cc-0d44-4b50-8888-8dd25736052a\"\n ]\n },\n \"name\": {\n \"any_\": [\n \"<string>\"\n ]\n },\n \"type\": {\n \"any_\": [\n \"<string>\"\n ]\n }\n },\n \"offset\": 0,\n \"limit\": 123\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/work_pools/filter")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"work_pools\": {\n \"operator\": \"and_\",\n \"id\": {\n \"any_\": [\n \"3c90c3cc-0d44-4b50-8888-8dd25736052a\"\n ]\n },\n \"name\": {\n \"any_\": [\n \"<string>\"\n ]\n },\n \"type\": {\n \"any_\": [\n \"<string>\"\n ]\n }\n },\n \"offset\": 0,\n \"limit\": 123\n}"
response = http.request(request)
puts response.read_body[
{
"id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"created": "2023-11-07T05:31:56Z",
"updated": "2023-11-07T05:31:56Z",
"name": "<string>",
"type": "<string>",
"description": "<string>",
"base_job_template": {},
"is_paused": false,
"concurrency_limit": 1,
"default_queue_id": "3c90c3cc-0d44-4b50-8888-8dd25736052a",
"storage_configuration": {
"bundle_upload_step": {},
"bundle_execution_step": {},
"default_result_storage_block_id": "3c90c3cc-0d44-4b50-8888-8dd25736052a"
},
"active_slots": 123
}
]{
"detail": [
{
"loc": [
"<string>"
],
"msg": "<string>",
"type": "<string>",
"input": "<unknown>",
"ctx": {}
}
]
}Headers
Body
application/json
Response
Successful Response
The name of the work pool.
Pattern:
^[^/%&><]+$The work pool type.
A description of the work pool.
The work pool's base job template.
Pausing the work pool stops the delivery of all work.
A concurrency limit for the work pool.
Required range:
x >= 0The current status of the work pool.
Available options:
READY, NOT_READY, PAUSED The id of the pool's default queue.
The storage configuration for the work pool.
Show child attributes
Show child attributes
The number of concurrency slots occupied by pending or running flow runs. None when concurrency_limit is not set.
Was this page helpful?
⌘I