From 14720ecf2b878d9fd766fe323a335e88f9b39281 Mon Sep 17 00:00:00 2001 From: Medusa Trade Date: Tue, 5 Jan 2021 13:42:54 -0500 Subject: [PATCH] always serialize channels and streams as list --- alpaca_trade_api/polygon/streamconn.py | 4 ++-- alpaca_trade_api/stream2.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/alpaca_trade_api/polygon/streamconn.py b/alpaca_trade_api/polygon/streamconn.py index 0068ae6f..d60b28ff 100644 --- a/alpaca_trade_api/polygon/streamconn.py +++ b/alpaca_trade_api/polygon/streamconn.py @@ -153,7 +153,7 @@ async def subscribe(self, channels): self._streams |= set(channels) await self._ws.send(json.dumps({ 'action': 'subscribe', - 'params': streams + 'params': list(streams) })) async def unsubscribe(self, channels): @@ -167,7 +167,7 @@ async def unsubscribe(self, channels): self._streams -= set(channels) await self._ws.send(json.dumps({ 'action': 'unsubscribe', - 'params': streams + 'params': list(streams) })) def run(self, initial_channels=[]): diff --git a/alpaca_trade_api/stream2.py b/alpaca_trade_api/stream2.py index a732bb2b..c945f46e 100644 --- a/alpaca_trade_api/stream2.py +++ b/alpaca_trade_api/stream2.py @@ -118,7 +118,7 @@ async def subscribe(self, channels): await self._ws.send(json.dumps({ 'action': 'listen', 'data': { - 'streams': channels, + 'streams': list(channels), } })) @@ -129,7 +129,7 @@ async def unsubscribe(self, channels): await self._ws.send(json.dumps({ 'action': 'unlisten', 'data': { - 'streams': channels, + 'streams': list(channels), } }))