connect

import { connect, definePipeline, field, root } from "@toloka-platform/sdk";

const text = field("text", { type: "string" });
const boundary = root({ started: [text], completed: [text] });

export default definePipeline({
  fields: [text],
  nodes: [boundary],
  connections: [connect(boundary.started, boundary.completed)],
});

import { connect, definePipeline, field, root } from "@toloka-platform/sdk";

const text = field("text", { type: "string" });
const boundary = root({ started: [text], completed: [text] });

export default definePipeline({
  fields: [text],
  nodes: [boundary],
  connections: [connect(boundary.started, boundary.completed)],
});

import type { Connection, InputPort, OutputPort, PipelineGraphV1 } from "@toloka-platform/sdk";

declare function connect(
  from: OutputPort,
  to: InputPort,
  settings?: PipelineGraphV1["connections"][number]["settings"],
): Connection;

Parameters

OutputPort

required

Source port: root started, a work node’s output, or a Match node’s matched(index) or default.

InputPort

required

Destination port: a work node’s input or root completed.

Record<string, unknown>

default:"{}"

Connection settings stored in the graph. Ordinary connections use the default empty object.

Returns

Connection

Add it to definePipeline({ connections }).

Show Connection properties

OutputPort

The supplied source port.

InputPort

The supplied destination port.

Record<string, unknown>

The supplied settings or {}.

TypeScript checks that the first port is an output and the second is an input. connect does not check field compatibility. definePipeline checks that the endpoint nodes are declared; use local and platform validation for the graph.

import { connect, definePipeline, field, root } from "@toloka-platform/sdk";

const text = field("text", { type: "string" });
const boundary = root({ started: [text], completed: [text] });

export default definePipeline({
  fields: [text],
  nodes: [boundary],
  connections: [connect(boundary.started, boundary.completed)],
});

Reference

TypeScript SDK

CLI

HTTP API

Parameters

Returns