Skip to content

Commit

Permalink
use exchange id in exchange channels
Browse files Browse the repository at this point in the history
  • Loading branch information
Guillaume De Saint Martin committed Jan 18, 2020
1 parent bb1ab90 commit f10293a
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion octobot_evaluators/evaluator/TA_evaluator.py
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,9 @@ async def start(self) -> None:
"""
try:
from octobot_trading.channels.exchange_channel import get_chan as get_trading_chan
await get_trading_chan(OctoBotTradingChannelsName.OHLCV_CHANNEL.value, self.exchange_name).new_consumer(
from octobot_trading.api.exchange import get_exchange_id_from_matrix_id
exchange_id = get_exchange_id_from_matrix_id(self.exchange_name, self.matrix_id)
await get_trading_chan(OctoBotTradingChannelsName.OHLCV_CHANNEL.value, exchange_id).new_consumer(
self.ohlcv_callback) # TODO filter
except ImportError:
self.logger.error("Can't connect to OHLCV trading channel")
Expand Down

0 comments on commit f10293a

Please sign in to comment.