removed excessive debug logs
This commit is contained in:
@@ -34,7 +34,7 @@ async def handle_backfill_uniswap_swaps(swaps: list[EventData]):
|
|||||||
data = await get_uniswap_data(swap)
|
data = await get_uniswap_data(swap)
|
||||||
if data is not None:
|
if data is not None:
|
||||||
pool, time, price = data
|
pool, time, price = data
|
||||||
log.debug(f'OHLC {pool["address"]} {time} {price}')
|
# log.debug(f'OHLC {pool["address"]} {time} {price}')
|
||||||
ohlcs.light_update_all(pool['address'], time, price)
|
ohlcs.light_update_all(pool['address'], time, price)
|
||||||
|
|
||||||
def flush_callback():
|
def flush_callback():
|
||||||
|
|||||||
@@ -414,17 +414,17 @@ class LightOHLCRepository (OHLCRepository):
|
|||||||
if price is not None:
|
if price is not None:
|
||||||
self.quotes[symbol] = timestamp(time), str(price)
|
self.quotes[symbol] = timestamp(time), str(price)
|
||||||
start = ohlc_start_time(time, period)
|
start = ohlc_start_time(time, period)
|
||||||
log.debug(f'OHLC start_time {start}')
|
# log.debug(f'OHLC start_time {start}')
|
||||||
chunk = self.get_chunk(symbol, period, start)
|
chunk = self.get_chunk(symbol, period, start)
|
||||||
key = symbol, period
|
key = symbol, period
|
||||||
prev = self.current.get(key)
|
prev = self.current.get(key)
|
||||||
if prev is None:
|
if prev is None:
|
||||||
# cache miss. load from chunk.
|
# cache miss. load from chunk.
|
||||||
prev = self.current[key] = chunk.bar_at(start)
|
prev = self.current[key] = chunk.bar_at(start)
|
||||||
log.debug(f'loaded prev bar from chunk {prev}')
|
# log.debug(f'loaded prev bar from chunk {prev}')
|
||||||
if prev is None:
|
if prev is None:
|
||||||
# not in cache or chunk. create new bar.
|
# not in cache or chunk. create new bar.
|
||||||
log.debug(f'no prev bar')
|
# log.debug(f'no prev bar')
|
||||||
if price is not None:
|
if price is not None:
|
||||||
close = price
|
close = price
|
||||||
else:
|
else:
|
||||||
|
|||||||
Reference in New Issue
Block a user