Skip to content

A
ai-api-mgr
Commit 7cace2e1 authored by Your Name's avatar Your Name
Browse files
Options

questdb error print

parent f043b95f
Show whitespace changes
Inline Side-by-side
Showing with 5 additions and 2 deletions
main.go
View file @ 7cace2e1
...@@ -274,7 +274,9 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent ...@@ -274,7 +274,9 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent
err = sender.Flush(ctx) err = sender.Flush(ctx)
if err != nil { if err != nil {
log.Fatal(err)
fmt.Println("task := <-resStream sender.Flush", err.Error())
//log.Fatal(err)
} }
case task := <-reqStream: case task := <-reqStream:
...@@ -317,7 +319,8 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent ...@@ -317,7 +319,8 @@ func batchToQuestDb(done chan interface{}, reqStream chan pbUpstream.TaskContent
err = sender.Flush(ctx) err = sender.Flush(ctx)
if err != nil { if err != nil {
log.Fatal(err) fmt.Println("task := <-reqStream sender.Flush", err.Error())
//log.Fatal(err)
} }
case <-done: case <-done:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment