in csharp/Microsoft.Azure.Databricks.Client/PipelinesApiClient.cs [158:190]
public async Task<string> Start(
string pipelineId,
bool fullRefresh = false,
PipelineUpdateCause cause = PipelineUpdateCause.API_CALL,
IEnumerable<string> refreshSelection = default,
IEnumerable<string> fullRefreshSelection = default,
CancellationToken cancellationToken = default)
{
var requestUri = $"{ApiVersion}/pipelines/{pipelineId}/updates";
var requestDict = new Dictionary<string, string>()
{
{ "full_refresh", fullRefresh.ToString().ToLower() },
{ "cause", cause.ToString() }
};
var request = JsonSerializer.SerializeToNode(requestDict, Options).AsObject();
if (refreshSelection != null)
{
var refreshSelectionJson = JsonSerializer.SerializeToNode(refreshSelection, Options);
request.Add("refresh_selection", refreshSelectionJson);
}
if (fullRefreshSelection != null)
{
var fullRefreshSelectionJson = JsonSerializer.SerializeToNode(fullRefreshSelection, Options);
request.Add("full_refresh_selection", fullRefreshSelectionJson);
}
var response = await HttpPost<JsonObject, JsonObject>(this.HttpClient, requestUri, request, cancellationToken).ConfigureAwait(false);
return response["update_id"].GetValue<string>();
}