diff --git a/src/pricing/collector.py b/src/pricing/collector.py
index 8972382..6ecdd6a 100644
--- a/src/pricing/collector.py
+++ b/src/pricing/collector.py
@@ -2,6 +2,8 @@
 
 from datetime import datetime, timedelta
 
+import sys
+
 from time import sleep
 
 from pricing.bitfinex import bitfinexPublicTicker, bitfinexHighLowVol
@@ -47,6 +49,7 @@ def averager(type):
     averagePrice = round(averagePrice, 3)
 
     print("Price: ", averagePrice)
+    sys.stdout.flush()
 
     return averagePrice, timestamp
 
@@ -89,7 +92,10 @@ def sendToGateway(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
     status, response = send(query)
 
     print("Status: ", status)
+    sys.stdout.flush()
+
     print("Response: ", response)
+    sys.stdout.flush()
 
 def getOpenClose(type):
     open, close = geminiOpenClose(type)
@@ -99,6 +105,7 @@ def getOpenClose(type):
 # Dynamically Spin up Child process for each type wanting to track
 def collector(c_type):
     print("Console: ", "== Historical Price Collector ==")
+    sys.stdout.flush()
 
     while True:
         av_price, timestamp = averager(c_type)