Ошибка asyncio Task was destroyed but it is pending?

Question

[SamKnight]

Помогите разобраться в чем ошибка. Вот исполняемый код:

import pandas as pd
import sqlalchemy
from binance.client import Client
from binance import BinanceSocketManager
import asyncio

client = Client(api_key, api_secret)

async def main():

    bsm = BinanceSocketManager(client)
    socket = bsm.trade_socket('BTCUSDT')
    await socket.__aenter__()
    msg = await socket.recv()
    return print(msg)

loop = asyncio.get_event_loop()
forecast = loop.run_until_complete(main())
loop.close()

Ошибка: Task was destroyed but it is pending! task: wait_for=()]> cb=[_release_waiter(()]>)() at /Users/v/Downloads/soft/anaconda3/lib/python3.9/asyncio/tasks.py:416]>

Comments

[Алан Гибизов]

Юпитер сам по-моему асинхронный, поэтому в нём не гарантируется корректная работа асинхронного кода.

Answer 1

[sichiiii]

Возможно это поможет:

for task in asyncio.Task.all_tasks(client.loop):
    task.cancel()

Comments

[SamKnight]

Спасибо за время, но это не сработало.