mirror of https://github.com/databricks/cli.git
Compare commits
4 Commits
40b8f7bbae
...
f27bd673c5
Author | SHA1 | Date |
---|---|---|
shreyas-goenka | f27bd673c5 | |
Shreyas Goenka | 50af744a97 | |
Shreyas Goenka | 9284fa1e1e | |
Shreyas Goenka | df97a5bb93 |
|
@ -90,11 +90,6 @@ func (r *pipelineRunner) Run(ctx context.Context, opts *Options) (output.RunOutp
|
|||
// Include resource key in logger.
|
||||
ctx = log.NewContext(ctx, log.GetLogger(ctx).With("resource", r.Key()))
|
||||
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)
|
||||
if err != nil {
|
||||
|
|
|
@ -90,8 +90,6 @@ func TestPipelineRunnerRestart(t *testing.T) {
|
|||
PipelineId: "123",
|
||||
}).Return(mockWait, nil)
|
||||
|
||||
pipelineApi.EXPECT().GetByPipelineId(mock.Anything, "123").Return(&pipelines.GetPipelineResponse{}, nil)
|
||||
|
||||
// Mock runner starting a new update
|
||||
pipelineApi.EXPECT().StartUpdate(mock.Anything, pipelines.StartUpdate{
|
||||
PipelineId: "123",
|
||||
|
|
Loading…
Reference in New Issue