From d15c24da2ba497d88933d0b5c203c91e8aed72dd Mon Sep 17 00:00:00 2001
From: andrewso <9V5f1FkzI2LD>
Date: Mon, 24 Feb 2020 17:09:10 +0000
Subject: [PATCH] [24.02.20] Missed out log flushing

---
 src/pricing/collector.py | 7 +++++++
 1 file changed, 7 insertions(+)

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)