diff --git a/src/pricing/collector.py b/src/pricing/collector.py index b787c86..97274db 100644 --- a/src/pricing/collector.py +++ b/src/pricing/collector.py @@ -98,14 +98,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