Pagination

The CRE GraphQL API uses page-number pagination, not cursor-based (Relay-style) pagination. List queries take an optional page: Page argument and return both a page of results and the total matching count.

The Page input

input Page {
  number: Int = 0
  size: Int = 10
}

Page is accepted by workflows, workflowDeployments, and workflowExecutions.

The count field

Every paginated response includes a count field alongside data — the total number of items matching the query across all pages, not just the current one.

query ListWorkflows($page: Page) {
  workflows(input: { page: $page }) {
    data {
      uuid
      name
    }
    count
  }
}

{
  "data": {
    "workflows": {
      "data": [
        { "uuid": "<WORKFLOW_UUID_1>", "name": "price-feed-monitor" },
        { "uuid": "<WORKFLOW_UUID_2>", "name": "keeper-bot" }
      ],
      "count": 47
    }
  }
}

There is no pageInfo, hasNextPage, or cursor field — you determine whether more pages exist yourself.

Paginating through all results

Because there's no hasNextPage flag, compute it from page.number, page.size, and the returned count:

1. Start with page.number = 0 and a fixed page.size (for example 50).
2. Send the request with { number: pageNumber, size: pageSize }.
3. Read `count` from the response.
4. More pages remain if (pageNumber + 1) * pageSize < count.
5. If more pages remain, increment pageNumber and repeat from step 2.
6. Stop once (pageNumber + 1) * pageSize >= count.

TypeScript

async function fetchAllWorkflows(apiKey: string): Promise<Workflow[]> {
  const pageSize = 50
  let pageNumber = 0
  let all: Workflow[] = []
  let total = Infinity

  while (pageNumber * pageSize < total) {
    const response = await fetch("https://api.cre.chain.link/graphql", {
      method: "POST",
      headers: {
        "Content-Type": "application/json",
        Authorization: `Apikey ${apiKey}`,
      },
      body: JSON.stringify({
        query: `
          query ListWorkflows($page: Page) {
            workflows(input: { page: $page }) {
              data { uuid name status }
              count
            }
          }
        `,
        variables: { page: { number: pageNumber, size: pageSize } },
      }),
    })

    const result = await response.json()
    const { data, count } = result.data.workflows
    all = all.concat(data)
    total = count
    pageNumber += 1
  }

  return all
}

Go

func fetchAllWorkflows(apiKey string) ([]Workflow, error) {
	const pageSize = 50
	pageNumber := 0
	var all []Workflow
	total := -1

	for total == -1 || pageNumber*pageSize < total {
		body, _ := json.Marshal(map[string]any{
			"query": `query ListWorkflows($page: Page) {
				workflows(input: { page: $page }) {
					data { uuid name status }
					count
				}
			}`,
			"variables": map[string]any{
				"page": map[string]int{"number": pageNumber, "size": pageSize},
			},
		})

		req, _ := http.NewRequest("POST", "https://api.cre.chain.link/graphql", bytes.NewBuffer(body))
		req.Header.Set("Content-Type", "application/json")
		req.Header.Set("Authorization", "Apikey "+apiKey)

		resp, err := http.DefaultClient.Do(req)
		if err != nil {
			return nil, err
		}

		var result workflowsPageResponse
		json.NewDecoder(resp.Body).Decode(&result)
		resp.Body.Close()

		all = append(all, result.Data.Workflows.Data...)
		total = result.Data.Workflows.Count
		pageNumber++
	}

	return all, nil
}

Related

• Page
• workflows
• workflowExecutions