Stored CodeGen scripts for a pipeline
curl --request GET \
--url http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts \
--header 'x-api-key: <api-key>'import requests
url = "http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts"
headers = {"x-api-key": "<api-key>"}
response = requests.get(url, headers=headers)
print(response.text)const options = {method: 'GET', headers: {'x-api-key': '<api-key>'}};
fetch('http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_PORT => "8080",
CURLOPT_URL => "http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => [
"x-api-key: <api-key>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("x-api-key", "<api-key>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts")
.header("x-api-key", "<api-key>")
.asString();require 'uri'
require 'net/http'
url = URI("http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts")
http = Net::HTTP.new(url.host, url.port)
request = Net::HTTP::Get.new(url)
request["x-api-key"] = '<api-key>'
response = http.request(request)
puts response.read_body{
"pipeline": "<string>",
"scripts": [
{
"kind": "dataQuality",
"instruction": "<string>",
"script": "<string>",
"generatedAt": "2023-11-07T05:31:56Z",
"model": "<string>",
"modelIsCurrent": true,
"status": "ready",
"pendingReason": "<string>",
"origin": "save",
"storage": "<string>",
"repoPath": "<string>",
"commitSha": "<string>",
"drift": true,
"headSha": "<string>",
"conflict": true,
"conflictReason": "<string>"
}
]
}Pipelines
Stored CodeGen scripts for a pipeline
The Python scripts the pipeline’s AI data-quality rule and AI transformation run. A script is generated when the pipeline is saved (from the source schema, no row values) or, when none can be used, by the first run that needs it, and every later run executes the stored script without a model call. A changed instruction or source schema regenerates it; a changed CodeGen model does not (modelIsCurrent is false then; use the regenerate endpoint to adopt the new model). With a code repository configured, new scripts are committed to it and runs execute the recorded commit; drift reports an edit made in the repository since then. Requires pipeline:read.
GET
/
api
/
v1
/
pipelines
/
{name}
/
codegen-scripts
Stored CodeGen scripts for a pipeline
curl --request GET \
--url http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts \
--header 'x-api-key: <api-key>'import requests
url = "http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts"
headers = {"x-api-key": "<api-key>"}
response = requests.get(url, headers=headers)
print(response.text)const options = {method: 'GET', headers: {'x-api-key': '<api-key>'}};
fetch('http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_PORT => "8080",
CURLOPT_URL => "http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
CURLOPT_HTTPHEADER => [
"x-api-key: <api-key>"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts"
req, _ := http.NewRequest("GET", url, nil)
req.Header.Add("x-api-key", "<api-key>")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts")
.header("x-api-key", "<api-key>")
.asString();require 'uri'
require 'net/http'
url = URI("http://localhost:8080/api/v1/pipelines/{name}/codegen-scripts")
http = Net::HTTP.new(url.host, url.port)
request = Net::HTTP::Get.new(url)
request["x-api-key"] = '<api-key>'
response = http.request(request)
puts response.read_body{
"pipeline": "<string>",
"scripts": [
{
"kind": "dataQuality",
"instruction": "<string>",
"script": "<string>",
"generatedAt": "2023-11-07T05:31:56Z",
"model": "<string>",
"modelIsCurrent": true,
"status": "ready",
"pendingReason": "<string>",
"origin": "save",
"storage": "<string>",
"repoPath": "<string>",
"commitSha": "<string>",
"drift": true,
"headSha": "<string>",
"conflict": true,
"conflictReason": "<string>"
}
]
}