Patch Pipeline

curl -X PATCH 'https://api.example.com/v0/pipelines/{pipeline_name}' \
  -H 'Authorization: Bearer YOUR_TOKEN' \
  -H 'Content-Type: application/json' \
  -d '{
  "name": null,
  "description": "This is a new description",
  "runtime_config": null,
  "program_code": "CREATE TABLE table3 ( col3 INT );",
  "udf_rust": null,
  "udf_toml": null,
  "program_config": null
}'

const response = await fetch('https://api.example.com/v0/pipelines/{pipeline_name}', {
  method: 'PATCH',
  headers: {
    'Content-Type': 'application/json',
    'Authorization': 'Bearer YOUR_TOKEN'
  },
  body: JSON.stringify({
  "name": null,
  "description": "This is a new description",
  "runtime_config": null,
  "program_code": "CREATE TABLE table3 ( col3 INT );",
  "udf_rust": null,
  "udf_toml": null,
  "program_config": null
})
});
 
const data = await response.json();
console.log(data);

interface ApiResponse {
  // shape your response here
}
 
const response: Response = await fetch('https://api.example.com/v0/pipelines/{pipeline_name}', {
  method: 'PATCH',
  headers: {
    'Content-Type': 'application/json',
    'Authorization': 'Bearer YOUR_TOKEN'
  },
  body: JSON.stringify({
  "name": null,
  "description": "This is a new description",
  "runtime_config": null,
  "program_code": "CREATE TABLE table3 ( col3 INT );",
  "udf_rust": null,
  "udf_toml": null,
  "program_config": null
})
});
 
const data = (await response.json()) as ApiResponse;
console.log(data);

import requests
 
url = "https://api.example.com/v0/pipelines/{pipeline_name}"
headers = {
    "Content-Type": "application/json",
    "Authorization": "Bearer YOUR_TOKEN"
}
payload = {
    "name": None,
    "description": "This is a new description",
    "runtime_config": None,
    "program_code": "CREATE TABLE table3 ( col3 INT );",
    "udf_rust": None,
    "udf_toml": None,
    "program_config": None
}
 
response = requests.request("patch", url, headers=headers, json=payload)
print(response.json())

package main
 
import (
	"fmt"
	"io"
	"net/http"
	"strings"
)
 
func main() {
	body := strings.NewReader(`{
  "name": null,
  "description": "This is a new description",
  "runtime_config": null,
  "program_code": "CREATE TABLE table3 ( col3 INT );",
  "udf_rust": null,
  "udf_toml": null,
  "program_config": null
}`)
	req, err := http.NewRequest("PATCH", "https://api.example.com/v0/pipelines/{pipeline_name}", body)
	if err != nil {
		panic(err)
	}
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Authorization", "Bearer YOUR_TOKEN")
 
	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		panic(err)
	}
	defer resp.Body.Close()
 
	out, _ := io.ReadAll(resp.Body)
	fmt.Println(string(out))
}

{
  "id": "67e55044-10b1-426f-9247-bb680e5fe0c8",
  "name": "example1",
  "description": "Description of the pipeline example1",
  "created_at": "1970-01-01T00:00:00Z",
  "version": 4,
  "platform_version": "v0",
  "runtime_config": {
    "workers": 16,
    "max_rss_mb": null,
    "hosts": 1,
    "storage": {
      "backend": {
        "name": "default"
      },
      "min_storage_bytes": null,
      "min_step_storage_bytes": null,
      "compression": "default",
      "cache_mib": null
    },
    "fault_tolerance": {
      "model": "none",
      "checkpoint_interval_secs": 60
    },
    "cpu_profiler": true,
    "tracing": false,
    "tracing_endpoint_jaeger": "",
    "min_batch_size_records": 0,
    "max_buffering_delay_usecs": 0,
    "resources": {
      "cpu_cores_min": null,
      "cpu_cores_max": null,
      "memory_mb_min": null,
      "memory_mb_max": null,
      "storage_mb_max": null,
      "storage_class": null,
      "service_account_name": null,
      "namespace": null
    },
    "clock_resolution_usecs": 1000000,
    "pin_cpus": [],
    "provisioning_timeout_secs": null,
    "max_parallel_connector_init": null,
    "init_containers": null,
    "checkpoint_during_suspend": true,
    "http_workers": null,
    "io_workers": null,
    "env": {},
    "dev_tweaks": {},
    "logging": null,
    "pipeline_template_configmap": null
  },
  "program_code": "CREATE TABLE table1 ( col1 INT );",
  "udf_rust": "",
  "udf_toml": "",
  "program_config": {
    "profile": "optimized",
    "cache": true,
    "runtime_version": null
  },
  "program_version": 2,
  "program_status": "Pending",
  "program_status_since": "1970-01-01T00:00:00Z",
  "program_error": {
    "sql_compilation": null,
    "rust_compilation": null,
    "system_error": null
  },
  "program_info": null,
  "deployment_error": null,
  "refresh_version": 4,
  "storage_status": "Cleared",
  "storage_status_details": null,
  "deployment_id": null,
  "deployment_initial": null,
  "deployment_status": "Stopped",
  "deployment_status_since": "1970-01-01T00:00:00Z",
  "deployment_desired_status": "Stopped",
  "deployment_desired_status_since": "1970-01-01T00:00:00Z",
  "deployment_resources_status": "Stopped",
  "deployment_resources_status_details": null,
  "deployment_resources_status_since": "1970-01-01T00:00:00Z",
  "deployment_resources_desired_status": "Stopped",
  "deployment_resources_desired_status_since": "1970-01-01T00:00:00Z",
  "deployment_runtime_status": null,
  "deployment_runtime_status_details": null,
  "deployment_runtime_status_since": null,
  "deployment_runtime_desired_status": null,
  "deployment_runtime_desired_status_since": null
}

{
  "message": "Unknown pipeline name 'non-existent-pipeline'",
  "error_code": "UnknownPipelineName",
  "details": {
    "pipeline_name": "non-existent-pipeline"
  }
}

{
  "message": "An entity with this name already exists",
  "error_code": "DuplicateName",
  "details": null
}