diff --git a/bin/marketmaker b/bin/marketmaker index e24e1dc..6b61559 100755 --- a/bin/marketmaker +++ b/bin/marketmaker @@ -6,6 +6,7 @@ import os import os.path import rx import sys +import threading import typing from decimal import Decimal @@ -250,10 +251,13 @@ pulse_disposable = rx.interval(args.pulse_interval).subscribe( on_next=lambda _: market_maker.pulse(context, model_state)) disposer.add_disposable(pulse_disposable) -print("Press to quit.") +# Wait - don't exit. Exiting will be handled by signals/interrupts. +waiter = threading.Event() +try: + waiter.wait() +except: + pass -# Wait - don't exit -input() print("Shutting down...") ws.close() disposer.dispose() diff --git a/mango/marketmaking/ordertracker.py b/mango/marketmaking/ordertracker.py index 7c2bf54..c2571f4 100644 --- a/mango/marketmaking/ordertracker.py +++ b/mango/marketmaking/ordertracker.py @@ -36,7 +36,6 @@ class OrderTracker: self.tracked += [order] def existing_orders(self, model_state: ModelState) -> typing.Sequence[mango.Order]: - print("Model State Orders", model_state.placed_orders) live_orders: typing.List[mango.Order] = [] for placed_order in model_state.placed_orders: details = self._find_tracked(placed_order.client_id)