From 1142a538ea2b64a5f7fab7b159e0ad738d70cfb7 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Mon, 22 Feb 2021 10:45:01 -0500 Subject: [PATCH] Don't forward errors without an order id --- piker/brokers/ib.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/piker/brokers/ib.py b/piker/brokers/ib.py index f3785763..1577f0f6 100644 --- a/piker/brokers/ib.py +++ b/piker/brokers/ib.py @@ -23,13 +23,14 @@ built on it) and thus actor aware API calls must be spawned with """ from contextlib import asynccontextmanager from dataclasses import asdict -from functools import partial from datetime import datetime +from functools import partial from typing import List, Dict, Any, Tuple, Optional, AsyncIterator, Callable import asyncio -import logging +from pprint import pformat import inspect import itertools +import logging import time import trio @@ -1216,4 +1217,10 @@ async def stream_trades( if isinstance(con, Contract): msg['contract'] = asdict(con) + if msg['reqid'] == -1: + log.error(pformat(msg)) + + # don't forward, it's pointless.. + continue + yield {'local_trades': (event_name, msg)}