DFS - indicate whether TrcDb reported a change so alternative actions… (

#1006) * DFS - indicate whether TrcDb reported a change so alternative actions can occur. * Fix concurrency unsafe code. * Look up flow alias.
trimble-oss · Mar 15, 2024 · 4b6f268 · 4b6f268
1 parent aeb82f5
commit 4b6f268
Show file tree

Hide file tree

Showing 8 changed files with 294 additions and 274 deletions.
diff --git a/atrium/buildopts/flowopts/flowopts.go b/atrium/buildopts/flowopts/flowopts.go
@@ -70,7 +70,7 @@ func ProcessAskFlumeEventMapper(askFlumeContext *flowcore.AskFlumeContext, query
 
 	// Not enough time to check how to implement above queries, so only runs the query below
 	for {
-		rows := tfmContext.CallDBQuery(tfContext, sql_query, nil, false, "SELECT", nil, "")
+		rows, _ := tfmContext.CallDBQuery(tfContext, sql_query, nil, false, "SELECT", nil, "")
 		encoded_rows, err := json.Marshal(rows)
 		if err != nil {
 			log.Printf("error encoding result from trcdb: %v", err)