mirror of https://github.com/databricks/cli.git
Compare commits
2 Commits
0e0907cb47
...
35f8fa716a
Author | SHA1 | Date |
---|---|---|
shreyas-goenka | 35f8fa716a | |
Shreyas Goenka | df97a5bb93 |
|
@ -90,11 +90,6 @@ func (r *pipelineRunner) Run(ctx context.Context, opts *Options) (output.RunOutp
|
||||||
// Include resource key in logger.
|
// Include resource key in logger.
|
||||||
ctx = log.NewContext(ctx, log.GetLogger(ctx).With("resource", r.Key()))
|
ctx = log.NewContext(ctx, log.GetLogger(ctx).With("resource", r.Key()))
|
||||||
w := r.bundle.WorkspaceClient()
|
w := r.bundle.WorkspaceClient()
|
||||||
_, err := w.Pipelines.GetByPipelineId(ctx, pipelineID)
|
|
||||||
if err != nil {
|
|
||||||
log.Warnf(ctx, "Cannot get pipeline: %s", err)
|
|
||||||
return nil, err
|
|
||||||
}
|
|
||||||
|
|
||||||
req, err := opts.Pipeline.toPayload(r.pipeline, pipelineID)
|
req, err := opts.Pipeline.toPayload(r.pipeline, pipelineID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Loading…
Reference in New Issue