Exceptions in on_message are swallowed in Google Colab

[timborden]

Here is sample code to reproduce the error in Google Colab:

from coinbase.websocket import WSClient

symbol = "BAT-USD"
num_changes = 10
changes = []

def on_message(message):
  m = json.loads(message)

  if m["channel"] not in ["l2_data", "market_trades"]:
    return

  changes.append(message)

  print(f"{len(changes)} changes logged ({m['channel']})")

  if len(changes) > num_changes / 2:
    raise Exception("Stop")

client = WSClient(on_message=on_message, verbose=True)
client.open()
client.subscribe(product_ids=[symbol], channels=["heartbeats", "level2", "market_trades"])

while len(changes) < num_changes:
  time.sleep(0.1)

client.unsubscribe(product_ids=[symbol], channels=["heartbeats", "level2", "market_trades"])
client.close()
print("Done")

[github-actions]

Thank you for reporting! If this is an SDK specific issue, we will look into it and get back to you soon. If this is an API related request, report it in our Advanced API Discord instead (use this invite link if it's your first time accessing the Discord).