in csharp/Microsoft.Azure.Databricks.Client/PipelinesApiClient.cs [49:68]
public async Task<(string, PipelineSpecification)> Create(
PipelineSpecification pipelineSpecification,
bool dryRun = true,
bool allowDuplicateNames = false,
CancellationToken cancellationToken = default)
{
var requestUri = $"{ApiVersion}/pipelines";
var request = JsonSerializer.SerializeToNode(pipelineSpecification, Options)!.AsObject();
request.Add("dry_run", dryRun);
request.Add("allow_duplicate_names", allowDuplicateNames);
var response = await HttpPost<JsonObject, JsonObject>
(this.HttpClient, requestUri, request, cancellationToken)
.ConfigureAwait(false);
return (
response["pipeline_id"]?.GetValue<string>(),
response["effective_settings"]?.AsObject().Deserialize<PipelineSpecification>(Options)
);
}