Remove leftover debug print (#26)

database/func.go

@@ -437,7 +437,7 @@ func (db *Database) UpdatePipelineRefs(pipelineId uuid.UUID, refsMap map[string]
 	query := `
 INSERT INTO pipeline_refs(name, pipeline_id, hash)
 VALUES($1, $2, $3)
-ON CONFLICT (name)
+ON CONFLICT (name, pipeline_id)
 DO
   UPDATE SET hash=$3;`
 

docker/publish.sh

@@ -1,4 +1,10 @@
 #!/bin/bash
 
-docker build . -f docker/Dockerfile -t git.ohea.xyz/cursorius/server:latest
-docker push git.ohea.xyz/cursorius/server:latest
+if [[ -z "${1}" ]]; then
+    echo "You must provide a docker tag to push to."
+else
+    echo "Building container git.ohea.xyz/cursorius/server:$1"
+    docker build . -f docker/cursorius/Dockerfile -t "git.ohea.xyz/cursorius/server:$1"
+    echo "Pushing container git.ohea.xyz/cursorius/server:$1"
+    docker push "git.ohea.xyz/cursorius/server:$1"
+fi

pipeline_executor/pipeline_executor.go

@@ -101,7 +101,7 @@ func ExecutePipeline(pe PipelineExecution, db database.Database, pipelineConf co
 		log.Errorf("%v: could not create docker client: %w", idStr, err)
 		return
 	}
-	log.Info("%v: source cloned successfully", idStr)
+	log.Infof("%v: source cloned successfully", idStr)
 
 	ctx := context.Background()
 
@@ -131,7 +131,7 @@ func ExecutePipeline(pe PipelineExecution, db database.Database, pipelineConf co
 	}
 	log.Debugf("%v: job source tarred", idStr)
 
-	log.Info("%v: building container", idStr)
+	log.Infof("%v: building container", idStr)
 
 	dockerBuildContext, err := os.Open(tarFile)
 	defer dockerBuildContext.Close()

runnermanager/runner.go

@@ -101,8 +101,6 @@ func (r *Runner) sendProtoStruct(p protoreflect.ProtoMessage) error {
 
 	ctx := context.Background()
 
-	log.Debugf("r.conn: %p", r.conn)
-
 	if err := r.conn.Write(ctx, websocket.MessageBinary, protoOut); err != nil {
 		return fmt.Errorf("Could not send proto to websocket: %w", err)
 	}