ohlc pub bugfix

src/dexorder/bin/mirror.py

@@ -78,7 +78,10 @@ async def main():
                 proms.append((tx, pool_addr, mirror_addr, mirror_inverted))
             except Exception as x:
                 log.exception(x)
-        await asyncio.gather(*[await_mirror(*args) for args in proms])
+        try:
+            await asyncio.gather(*[await_mirror(*args) for args in proms], return_exceptions=True)
+        except Exception as x:
+            log.exception(x)
         await asyncio.sleep(delay)
 
 

src/dexorder/ohlc.py

@@ -451,7 +451,7 @@ def pub_ohlc(_series:str, key: OHLCKey, bars: list[NativeOHLC]):
     chain_id = current_chain.get().chain_id
     return (
         f'{chain_id}|{pool_addr}|{period_name(period)}',  # channel name is like 0x...|1m
-        'ohlcs',
+        'ohlc',
         (chain_id, pool_addr, [b.ohlc for b in bars])
     )