fixup! chore: event_payload column can be JSONB, BYTEA or TEXT

rudderlabs · Dec 13, 2024 · c5c21e3 · c5c21e3
1 parent 58a72f5
commit c5c21e3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/jobsdb/jobsdb.go b/jobsdb/jobsdb.go
@@ -792,7 +792,9 @@ func (jd *Handle) init() {
 		jd.config = config.Default
 	}
 
-	jd.conf.payloadColumnType = payloadColumnType(jd.config.GetIntVar(0, 1, jd.tablePrefix+"."+string(jd.ownerType)+".payloadColumnType", jd.tablePrefix+".payloadColumnType"))
+	if jd.conf.payloadColumnType == 0 {
+		jd.conf.payloadColumnType = payloadColumnType(jd.config.GetIntVar(0, 1, "JobsDB."+jd.tablePrefix+"."+string(jd.ownerType)+".payloadColumnType", "JobsDB."+jd.tablePrefix+".payloadColumnType"))
+	}
 
 	if jd.stats == nil {
 		jd.stats = stats.Default