payload = {
"clusters": [
{
"num_workers": 4
}
],
"pipeline_id": pipeline_id
}
update_url = f"{workspace_url}/api/2.0/pipelines/{pipeline_id}"response = requests.put(update_url, headers=headers, json=payload)
for this, i'm getting below output with status code 400.
{"error_code":"INVALID_PARAMETER_VALUE","message":"Cannot modify catalog of an existing pipeline. Existing catalog: 'doha'. Requested catalog: ''"}
i also have tried with
url = f"{workspace_url}/api/2.0/pipelines/{pipeline_id}"
response = requests.get(url, headers=headers)
response.json()
using above response and modifying the num_workers, without changing any catalog parameter and also with catalog parameter same as previous. but still getting same error..
kindly help