Fix: change group id in the file coordinator service

liel-almog · Mar 17, 2024 · 09a0d89 · 09a0d89
1 parent d81a81a
commit 09a0d89
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/storage-coordinator/file-delete.go b/storage-coordinator/file-delete.go
@@ -38,7 +38,7 @@ func fileDelete(connString string) {
 	r := kafka.NewReader(kafka.ReaderConfig{
 		Brokers: strings.Split(brokers, ","),
 		Topic:   fileDeleteTopic,
-		GroupID: "upload-permanent-backup",
+		GroupID: "delete-permanent-backup",
 	})
 
 	for {

diff --git a/storage-coordinator/file-upload.go b/storage-coordinator/file-upload.go
@@ -116,7 +116,7 @@ func fileUpload(connString string) {
 	r := kafka.NewReader(kafka.ReaderConfig{
 		Brokers: strings.Split(brokers, ","),
 		Topic:   fileUplaodFinilizationTopic,
-		GroupID: "delete-permanent-backup",
+		GroupID: "upload-permanent-backup",
 	})
 
 	for {
@@ -148,12 +148,12 @@ func fileUpload(connString string) {
 			wg.Done()
 		}()
 
-		wg.Wait()
-		r.CommitMessages(context.Background(), m)
 		url := fmt.Sprintf("https://%s.blob.core.windows.net/%s/%s", stgAccountName, permanentContainerName, fileName)
-
 		_, err = db.Pool.Exec(context.Background(), "UPDATE files SET status = 'uploaded', url = $1 WHERE file_id = $2", url, *payload.FileId)
 
+		wg.Wait()
+		r.CommitMessages(context.Background(), m)
+
 		if err != nil {
 			panic(err)
 		}