put
Developing
PUT
flows/{id}
Request
Path Params
Body Params application/json
Responses
Request Request Example
Shell
JavaScript
Java
Swift
curl --location --request PUT 'flows/' \
--header 'Authorization: Bearer <token>' \
--header 'Content-Type: application/json' \
--data-raw '{
"": {
"projectId": "string",
"name": "string",
"description": "string",
"version": "string",
"metadata": {},
"tags": [
"string"
],
"nodes": [
{
"id": "string",
"type": "string",
"position": {
"x": 0,
"y": 0
},
"data": {},
"displayOrder": 0,
"connectionId": "string"
}
],
"edges": [
{
"id": "string",
"source": "string",
"target": "string",
"sourceHandle": "string",
"targetHandle": "string",
"metadata": {}
}
],
"connectionId": "string"
}
}'Response Response Example
{
"message": "Flow updated successfully",
"flow": {
"id": "2895ac8d-b6db-469c-9f39-5180a051918c",
"projectId": "8dbae2e7-911e-476c-9861-e368613f09dc",
"createdById": "00000000-0000-0000-0000-000000000001",
"name": "m2s_demo_job",
"description": null,
"version": "1.0",
"metadata": {
"catalog": "hive_prod"
},
"tags": [],
"createdAt": "2026-02-04T06:32:58.329Z",
"updatedAt": "2026-02-04T06:40:53.945Z",
"lockedById": null,
"lockedAt": null,
"nodes": [
{
"id": "b2f3afc1-6e32-424e-8aa0-b70c68b514a1",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"type": "source",
"position": {
"x": 80,
"y": 80
},
"data": {
"alias": "txn",
"table": "dm.txn",
"sourceType": "table"
},
"displayOrder": 0,
"createdAt": "2026-02-04T06:40:53.934Z",
"updatedAt": "2026-02-04T06:40:53.934Z"
},
{
"id": "5875ac5f-41bd-41e5-bfab-281039b6a630",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"type": "filter",
"position": {
"x": 380,
"y": 90
},
"data": {
"condition": "amount > 0"
},
"displayOrder": 1,
"createdAt": "2026-02-04T06:40:53.936Z",
"updatedAt": "2026-02-04T06:40:53.936Z"
},
{
"id": "7033eaed-0109-42de-a620-12f3248a7ce3",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"type": "aggregate",
"position": {
"x": 680,
"y": 80
},
"data": {
"aggs": [
{
"expr": "sum(amount)",
"alias": "total_amount"
},
{
"expr": "count(1)",
"alias": "tx_count"
}
],
"groupBy": [
"customer_id"
]
},
"displayOrder": 2,
"createdAt": "2026-02-04T06:40:53.937Z",
"updatedAt": "2026-02-04T06:40:53.937Z"
},
{
"id": "494b1d1f-38cd-424b-b1e7-df85d7768669",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"type": "source",
"position": {
"x": 680,
"y": 260
},
"data": {
"path": "/data/raw/customers",
"alias": "customers",
"format": "parquet",
"sourceType": "path"
},
"displayOrder": 3,
"createdAt": "2026-02-04T06:40:53.938Z",
"updatedAt": "2026-02-04T06:40:53.938Z"
},
{
"id": "e8f00a03-1054-460c-bf37-e5a36f8a8d58",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"type": "join",
"position": {
"x": 980,
"y": 170
},
"data": {
"on": "l.customer_id = r.id",
"how": "left",
"leftKey": "customer_id",
"rightKey": "id"
},
"displayOrder": 4,
"createdAt": "2026-02-04T06:40:53.939Z",
"updatedAt": "2026-02-04T06:40:53.939Z"
},
{
"id": "7ddca934-4f87-459e-b81e-85fe52b7a090",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"type": "derive",
"position": {
"x": 1280,
"y": 170
},
"data": {
"columns": [
{
"expr": "total_amount / nullif(tx_count, 0)",
"name": "avg_txn"
}
]
},
"displayOrder": 5,
"createdAt": "2026-02-04T06:40:53.940Z",
"updatedAt": "2026-02-04T06:40:53.940Z"
},
{
"id": "5379d356-7e7f-4281-a9d2-9d18764717e4",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"type": "sink",
"position": {
"x": 1580,
"y": 170
},
"data": {
"keys": [
"customer_id"
],
"table": "dm.customer_metrics",
"catalog": "hive_prod",
"sinkType": "iceberg_merge"
},
"displayOrder": 6,
"createdAt": "2026-02-04T06:40:53.941Z",
"updatedAt": "2026-02-04T06:40:53.941Z"
}
],
"edges": [
{
"id": "a414c187-f8ef-4d63-afa2-b105193100fd",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"source": "b2f3afc1-6e32-424e-8aa0-b70c68b514a1",
"target": "5875ac5f-41bd-41e5-bfab-281039b6a630",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-04T06:40:53.943Z",
"updatedAt": "2026-02-04T06:40:53.943Z"
},
{
"id": "de6cc6b8-373d-432d-a845-fdb2d5ce4d3e",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"source": "5875ac5f-41bd-41e5-bfab-281039b6a630",
"target": "7033eaed-0109-42de-a620-12f3248a7ce3",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-04T06:40:53.943Z",
"updatedAt": "2026-02-04T06:40:53.943Z"
},
{
"id": "b278c018-c9fc-49ab-81b7-22b88471a1d5",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"source": "7033eaed-0109-42de-a620-12f3248a7ce3",
"target": "e8f00a03-1054-460c-bf37-e5a36f8a8d58",
"sourceHandle": "out",
"targetHandle": "left",
"metadata": {},
"createdAt": "2026-02-04T06:40:53.943Z",
"updatedAt": "2026-02-04T06:40:53.943Z"
},
{
"id": "54060fd5-dea9-44f7-b97f-24263c2ecf62",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"source": "494b1d1f-38cd-424b-b1e7-df85d7768669",
"target": "e8f00a03-1054-460c-bf37-e5a36f8a8d58",
"sourceHandle": "out",
"targetHandle": "right",
"metadata": {},
"createdAt": "2026-02-04T06:40:53.943Z",
"updatedAt": "2026-02-04T06:40:53.943Z"
},
{
"id": "e5c194f5-51f6-48dd-8328-a9b512fcdf5a",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"source": "e8f00a03-1054-460c-bf37-e5a36f8a8d58",
"target": "7ddca934-4f87-459e-b81e-85fe52b7a090",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-04T06:40:53.943Z",
"updatedAt": "2026-02-04T06:40:53.943Z"
},
{
"id": "4a76102e-633f-48ee-bd5e-23937a5979eb",
"flowId": "2895ac8d-b6db-469c-9f39-5180a051918c",
"source": "7ddca934-4f87-459e-b81e-85fe52b7a090",
"target": "5379d356-7e7f-4281-a9d2-9d18764717e4",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-04T06:40:53.943Z",
"updatedAt": "2026-02-04T06:40:53.943Z"
}
],
"createdBy": {
"id": "00000000-0000-0000-0000-000000000001",
"email": "admin@spark.local",
"name": "Default Admin"
},
"lockedBy": null
}
}Modified at 2026-02-03 14:33:38