Last local use of provision.

apache · Mar 30, 2023 · 74ce064 · 74ce064
1 parent dd7a249
commit 74ce064
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sdks/go/pkg/beam/runners/universal/runnerlib/job.go b/sdks/go/pkg/beam/runners/universal/runnerlib/job.go
@@ -20,14 +20,14 @@ import (
 	"fmt"
 	"io"
 
+	"github.com/apache/beam/sdks/v2/go/container/tools"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/hooks"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam/internal/errors"
 	"github.com/apache/beam/sdks/v2/go/pkg/beam/log"
 	jobpb "github.com/apache/beam/sdks/v2/go/pkg/beam/model/jobmanagement_v1"
 	pipepb "github.com/apache/beam/sdks/v2/go/pkg/beam/model/pipeline_v1"
-	"github.com/apache/beam/sdks/v2/go/pkg/beam/provision"
 	"github.com/golang/protobuf/proto"
 )
 
@@ -63,7 +63,7 @@ func Prepare(ctx context.Context, client jobpb.JobServiceClient, p *pipepb.Pipel
 		Parallelism:  opt.Parallelism,
 	}
 
-	options, err := provision.OptionsToProto(raw)
+	options, err := tools.OptionsToProto(raw)
 	if err != nil {
 		return "", "", "", errors.WithContext(err, "producing pipeline options")
 	}