From 883045beec490ef8009c6fac14826db82413b591 Mon Sep 17 00:00:00 2001
From: andrewso <9V5f1FkzI2LD>
Date: Thu, 9 Jul 2020 20:14:58 +0100
Subject: [PATCH] [09.07.20] Paths

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

diff --git a/src/pricing/collector.py b/src/pricing/collector.py
index 460a936..a109d63 100644
--- a/src/pricing/collector.py
+++ b/src/pricing/collector.py
@@ -13,7 +13,7 @@ from pricing.gemini import geminiPublicTicker, geminiVolAskBid, geminiDailyOpenC
 from pricing.bitstamp import bitstampVolAskBid, bitstampHighLow, bitstampOpenClose
 from pricing.kraken import krakenVolAskBid, krakenHighLow, krakenOpenClose
 
-from utils.databaseConnect import send
+from src.utils.databaseConnect import send
 
 import logging as logger
 
@@ -23,7 +23,7 @@ logger.basicConfig(
     datefmt='%Y-%m-%d %H:%M:%S'
 )
 
-btc_usd="src/resources/queries/V1_INSERT_NEW_PRICE_RECORD_BTC.graphql"
+btc_usd="/home/price-collector/src/resources/queries/V1_INSERT_NEW_PRICE_RECORD_BTC.graphql"
 
 def averager(type):
 
@@ -95,14 +95,14 @@ def sendToGateway(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
 
     logger.info("Query sending down to db-gateway -- ({})".format(query))
 
-    # status, response = send(query, logger)
-    #
-    # if status != 200:
-    #     logger.critical("Query wasn't executed properly, view logs. Status = {}".format(status))
-    #     logger.error("With Response of : {}".format(response))
-    # else:
-    #     logger.info("Query executed successfully with Status = {}".format(status))
-    #     logger.info("With Response of : {}".format(response))
+    status, response = send(query, logger)
+
+    if status != 200:
+        logger.critical("Query wasn't executed properly, view logs. Status = {}".format(status))
+        logger.error("With Response of : {}".format(response))
+    else:
+        logger.info("Query executed successfully with Status = {}".format(status))
+        logger.info("With Response of : {}".format(response))
 
 def timeFunction():
     global time