From eaa2a9b05d042d1c7cb0364da3f522d9d5f40833 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 22 Nov 2018 16:31:53 -0500 Subject: [PATCH] Port streaming test to new `data` module --- tests/test_tractor.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/test_tractor.py b/tests/test_tractor.py index 83e087a3..7e63e3a7 100644 --- a/tests/test_tractor.py +++ b/tests/test_tractor.py @@ -15,7 +15,7 @@ async def rx_price_quotes_from_brokerd(us_symbols): # no brokerd actor found portal = await nursery.start_actor( 'brokerd', - rpc_module_paths=['piker.brokers.core'], + rpc_module_paths=['piker.brokers.data'], statespace={ 'broker2tickersubs': {}, 'clients': {}, @@ -26,11 +26,11 @@ async def rx_price_quotes_from_brokerd(us_symbols): # gotta expose in a broker agnostic way... # retrieve initial symbol data # sd = await portal.run( - # 'piker.brokers.core', 'symbol_data', symbols=us_symbols) + # 'piker.brokers.data', 'symbol_data', symbols=us_symbols) # assert list(sd.keys()) == us_symbols gen = await portal.run( - 'piker.brokers.core', + 'piker.brokers.data', 'start_quote_stream', broker='robinhood', tickers=us_symbols,