client.pipelines.replaceGraph()

import assert from "node:assert/strict";
import { createClient } from "@toloka-platform/sdk";

const client = createClient({
  baseUrl: "https://platform.toloka.ai",
  apiKey: process.env.TOLOKA_API_KEY!,
});

const snapshot = await client.pipelines.getGraph({ pipelineId: "pl.019a0000-0000-7000-8000-000000000001" });
const graph = structuredClone(snapshot.graph);
const root = graph.nodes.find((node) => node.type === "root");
assert(root, "The pipeline has no Start node.");
root.settings.itemLimit = 100;

const pipeline = await client.pipelines.replaceGraph({
  pipelineId: "pl.019a0000-0000-7000-8000-000000000001",
  graph: graph,
  expectedVersion: snapshot.version
});
console.log(pipeline);

{
  "id": "pl.019a0000-0000-7000-8000-000000000001",
  "projectId": "pp.019a0000-0000-7000-8000-000000000001",
  "name": "<string>",
  "version": 0,
  "createdAt": "2026-01-01T00:00:00Z",
  "updatedAt": "2026-01-01T00:00:00Z"
}

import assert from "node:assert/strict";
import { createClient } from "@toloka-platform/sdk";

const client = createClient({
  baseUrl: "https://platform.toloka.ai",
  apiKey: process.env.TOLOKA_API_KEY!,
});

const snapshot = await client.pipelines.getGraph({ pipelineId: "pl.019a0000-0000-7000-8000-000000000001" });
const graph = structuredClone(snapshot.graph);
const root = graph.nodes.find((node) => node.type === "root");
assert(root, "The pipeline has no Start node.");
root.settings.itemLimit = 100;

const pipeline = await client.pipelines.replaceGraph({
  pipelineId: "pl.019a0000-0000-7000-8000-000000000001",
  graph: graph,
  expectedVersion: snapshot.version
});
console.log(pipeline);

{
  "id": "pl.019a0000-0000-7000-8000-000000000001",
  "projectId": "pp.019a0000-0000-7000-8000-000000000001",
  "name": "<string>",
  "version": 0,
  "createdAt": "2026-01-01T00:00:00Z",
  "updatedAt": "2026-01-01T00:00:00Z"
}

Send the complete graph, up to 2 MiB, and optionally expectedVersion. Returns the updated pipeline metadata. Invalid configuration or missing secrets returns 400; failed checks and lint findings do not block this write. An attached dataset cannot be removed. A stale version, concurrent edit, or active run returns 409; read the graph again before retrying.

Signature

Method signature on client.pipelines:

replaceGraph(args: {
  pipelineId: string;
  graph: PipelineGraphV1;
  expectedVersion?: string;
} | {
  pipelineId: string;
  graph: PipelineGraphV1;
  version: string;
  invalidFieldSchemas: InvalidFieldSchema[];
}): Promise<Pipeline>;

Parameters

Pass one of the argument shapes shown in the signature.

string

required

Pipeline ID with prefix pl..

PipelineGraphV1

required

Complete pipeline graph in version 1 of the public graph format.

Show Fields

required

Graph format version; always 1.

object[]

required

Fields used by the pipeline, with names and JSON Schemas.See the HTTP endpoint for the complete schema.

(RootNode | CodeNode | GenerationNode | MatchNode | QuorumNode)[]

required

Nodes that make up the pipeline.See the HTTP endpoint for the complete schema.

object[]

required

Directed connections between node handles.See the HTTP endpoint for the complete schema.

object

Optional node positions for the visual editor, keyed by node ID and block group; each position is an [x, y] pair.

Show Fields

object

string

The snapshot version expected to still be active. A stale version is rejected with HTTP 409.

string

The snapshot version. The SDK sends it as expectedVersion when you pass a graph snapshot.

InvalidFieldSchema[]

Snapshot diagnostics accepted when passing a complete graph snapshot. The SDK sends only graph and version (as expectedVersion); these diagnostics are not submitted.

Show Fields

string

required

The id of the field in graph.fields.

string

required

The stored JSON Schema text, exactly as saved.

string

required

Why the stored text is not a usable JSON Schema.

Returns

Promise<Pipeline> A pipeline within a project.

PipelineId

required

Pipeline ID with prefix pl..

ProjectId

required

Project ID with prefix pp..

string

required

Name of the pipeline.

number

required

Pipeline version number; copying a pipeline increments the source version.

string

required

Time the pipeline was created, as an ISO 8601 timestamp.

string

required

Time the pipeline was last updated, as an ISO 8601 timestamp.

Errors

HTTP errors throw PotatoApiError. The endpoint documents these error responses:

Status	Description
400	Pipeline graph is too large, invalid, or references missing secrets
404	Pipeline not found
409	The expected graph version is stale, the graph changed while the request was processed, or the pipeline has an active run and cannot be changed
429	Rate limit exceeded

HTTP endpoint: PUT /pipelines/{pipelineId}/graph.

import assert from "node:assert/strict";
import { createClient } from "@toloka-platform/sdk";

const client = createClient({
  baseUrl: "https://platform.toloka.ai",
  apiKey: process.env.TOLOKA_API_KEY!,
});

const snapshot = await client.pipelines.getGraph({ pipelineId: "pl.019a0000-0000-7000-8000-000000000001" });
const graph = structuredClone(snapshot.graph);
const root = graph.nodes.find((node) => node.type === "root");
assert(root, "The pipeline has no Start node.");
root.settings.itemLimit = 100;

const pipeline = await client.pipelines.replaceGraph({
  pipelineId: "pl.019a0000-0000-7000-8000-000000000001",
  graph: graph,
  expectedVersion: snapshot.version
});
console.log(pipeline);

{
  "id": "pl.019a0000-0000-7000-8000-000000000001",
  "projectId": "pp.019a0000-0000-7000-8000-000000000001",
  "name": "<string>",
  "version": 0,
  "createdAt": "2026-01-01T00:00:00Z",
  "updatedAt": "2026-01-01T00:00:00Z"
}

Reference

TypeScript SDK

CLI

HTTP API

client.pipelines.replaceGraph()

Signature

Parameters

Returns

Errors

​Signature

​Parameters

​Returns

​Errors

Signature

Parameters

Returns

Errors