Merge pull request #46 from mdr0id/remove_go_routine_db_write

Remove go routine that causes threading issues when writing to local db
5 years ago · f2aacce0ca
1 changed files with 1 additions and 2 deletions
--- a/cmd/ingest/main.go
+++ b/cmd/ingest/main.go
@ -157,8 +157,7 @@ func main() {
 		switch string(topic) {

 		case opts.zmqTopic:
-			// there's an implicit mutex here
-			go handleBlock(db, sequence, body)
+			handleBlock(db, sequence, body)

 		default:
 			log.WithFields(logrus.Fields{