added debug logs

Canva · Apr 5, 2023 · 0ebe2a4 · 0ebe2a4
1 parent f212170
commit 0ebe2a4
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/internal/component/output/async_writer.go b/internal/component/output/async_writer.go
@@ -212,12 +212,16 @@ func (w *AsyncWriter) loop() {
 		for {
 			var ts message.Transaction
 			var open bool
+			w.log.Tracef("I have entered the transaction here\n")
 			select {
 			case ts, open = <-w.transactions:
 				if !open {
+					w.log.Tracef("Transaction channel is not open. Returning..\n")
 					return
 				}
+				w.log.Tracef("Safely continue and transfer the transactions\n")
 			case <-w.shutSig.CloseAtLeisureChan():
+				w.log.Tracef("Shutdown at leisure has been triggered. Returning\n")
 				return
 			}