RunPipeline FIXME
(pipeline models.NewPipeline)
| 370 | |
| 371 | // RunPipeline FIXME |
| 372 | func (d *DevlakeClient) RunPipeline(pipeline models.NewPipeline) models.Pipeline { |
| 373 | d.testCtx.Helper() |
| 374 | pipelineResult := sendHttpRequest[models.Pipeline](d.testCtx, d.timeout, &testContext{ |
| 375 | client: d, |
| 376 | printPayload: true, |
| 377 | inlineJson: false, |
| 378 | }, http.MethodPost, fmt.Sprintf("%s/pipelines", d.Endpoint), nil, &pipeline) |
| 379 | return d.monitorPipeline(pipelineResult.ID) |
| 380 | } |
| 381 | |
| 382 | func mapToQueryString(queryParams map[string]string) string { |
| 383 | params := make([]string, 0) |