From bb8fade16f92b0a556bad5bfaf20c00ea0bef2ca Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sun, 30 Jan 2022 12:46:54 -0500 Subject: [PATCH] Update `msgpub` import from `tractor.experimental` --- piker/brokers/data.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/piker/brokers/data.py b/piker/brokers/data.py index 035d6f4c..f0a8d367 100644 --- a/piker/brokers/data.py +++ b/piker/brokers/data.py @@ -38,6 +38,7 @@ import contextlib import trio import tractor +from tractor.experimental import msgpub from async_generator import asynccontextmanager from ..log import get_logger, get_console_log @@ -98,7 +99,7 @@ class BrokerFeed: ) -@tractor.trionics.msgpub(tasks=['stock', 'option']) +@msgpub(tasks=['stock', 'option']) async def stream_poll_requests( get_topics: Callable, get_quotes: Coroutine,