sink-server: slight refactor of Create func

streamingfast · Nov 29, 2023 · 20bb46f · 20bb46f
1 parent 9961e62
commit 20bb46f
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/sink-server/docker/docker.go b/sink-server/docker/docker.go
@@ -138,10 +138,6 @@ func (e *DockerEngine) Create(ctx context.Context, deploymentID string, pkg *pbs
 	e.mutex.Lock()
 	defer e.mutex.Unlock()
 
-	return e.create(ctx, deploymentID, pkg, zlog)
-}
-
-func (e *DockerEngine) create(ctx context.Context, deploymentID string, pkg *pbsubstreams.Package, zlog *zap.Logger) (*pbsinksvc.InfoResponse, error) {
 	if e.otherDeploymentIsActive(ctx, "!NO_MATCH!", zlog) {
 		return nil, fmt.Errorf("this substreams-sink engine only supports a single active deployment. Stop any active sink before launching another one or use `sink-update`")
 	}