Revert "[06.10.20] Fixed some logging"
This reverts commit aa8b22a8
This commit is contained in:
parent
d727655cdf
commit
366ea11345
@ -38,7 +38,6 @@ def averager(type):
|
||||
averagePrice = round(averagePrice, 2)
|
||||
|
||||
log("Hourly Price for ({}) is {}".format(timestamp ,averagePrice), 'INFO')
|
||||
sleep(0.05)
|
||||
|
||||
return averagePrice, timestamp
|
||||
|
||||
@ -124,9 +123,7 @@ def sentToArtemis(c_type, timestamp, av_price, high, low, vol, o_price, c_price)
|
||||
messageJson = json.dumps(message, indent = 4)
|
||||
|
||||
log("Sending message to PricingSave queue", 'INFO')
|
||||
sleep(0.05)
|
||||
log("Message: {}".format(message), 'INFO')
|
||||
sleep(0.05)
|
||||
|
||||
activeMQSender(messageJson)
|
||||
|
||||
@ -163,12 +160,10 @@ def collector(c_type):
|
||||
schedule.every().hour.at(time).do(collector, c_type).tag("collector")
|
||||
|
||||
log("Collection will run again at {} every hour".format(time), 'INFO')
|
||||
sleep(0.05)
|
||||
|
||||
# Dynamically Spin up Child process for each type wanting to track
|
||||
def collectorMain(c_type):
|
||||
log("== Historical Price Collector ==", 'INFO')
|
||||
sleep(0.05)
|
||||
|
||||
collector(c_type)
|
||||
|
||||
|
||||
@ -4,7 +4,6 @@ import stomp
|
||||
import os
|
||||
|
||||
from src.utils.jsonLogger import log
|
||||
from time import sleep
|
||||
|
||||
class keys():
|
||||
|
||||
@ -22,8 +21,6 @@ def activeMQSender(message):
|
||||
addr, port, mqUser, mqPass = keys().returnKeys()
|
||||
|
||||
log("Attempting Connection to Artemis...", 'INFO')
|
||||
sleep(0.05)
|
||||
|
||||
con = stomp.Connection([(addr, port)], auto_content_length=False)
|
||||
con.connect( mqUser, mqPass, wait=True)
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user