Compare commits

...

2 Commits

Author SHA1 Message Date
restitux dcaeaeb6d6 Fix pipeline executor logging to use Infof 2023-05-04 20:27:33 -06:00
restitux 32a86ace9f Update ON CONFLICT with pipeline_refs primary key 2023-05-04 20:26:43 -06:00
2 changed files with 3 additions and 3 deletions
+1 -1
View File
@@ -437,7 +437,7 @@ func (db *Database) UpdatePipelineRefs(pipelineId uuid.UUID, refsMap map[string]
query := ` query := `
INSERT INTO pipeline_refs(name, pipeline_id, hash) INSERT INTO pipeline_refs(name, pipeline_id, hash)
VALUES($1, $2, $3) VALUES($1, $2, $3)
ON CONFLICT (name) ON CONFLICT (name, pipeline_id)
DO DO
UPDATE SET hash=$3;` UPDATE SET hash=$3;`
+2 -2
View File
@@ -101,7 +101,7 @@ func ExecutePipeline(pe PipelineExecution, db database.Database, pipelineConf co
log.Errorf("%v: could not create docker client: %w", idStr, err) log.Errorf("%v: could not create docker client: %w", idStr, err)
return return
} }
log.Info("%v: source cloned successfully", idStr) log.Infof("%v: source cloned successfully", idStr)
ctx := context.Background() ctx := context.Background()
@@ -131,7 +131,7 @@ func ExecutePipeline(pe PipelineExecution, db database.Database, pipelineConf co
} }
log.Debugf("%v: job source tarred", idStr) log.Debugf("%v: job source tarred", idStr)
log.Info("%v: building container", idStr) log.Infof("%v: building container", idStr)
dockerBuildContext, err := os.Open(tarFile) dockerBuildContext, err := os.Open(tarFile)
defer dockerBuildContext.Close() defer dockerBuildContext.Close()