Как решить ошибку: asyncpg.exceptions._base.InterfaceError: cannot perform operation: another operation is in progress?

Question

[Nikita235]

У меня есть бот. В нем я реализую сбор некоторых пользовательских данных.
В этом блоке прописываю запрос на добавление кошелька.

async def add_wallet(wallet: str):
    sql = 'INSERT INTO users (wallet) VALUES ($1)'
    await db.pool.execute(sql, wallet)

Это блок из основного файла. Именно здесь прописана основная логика бота.

@router.message(StateFilter(TonToken.wallet),
                       lambda x: x.text.isalnum and len(x.text) == 48)
async def save_wallet(message: Message, state=FSMContext):
    data = await state.update_data(wallet=message.text)
    await add_wallet(data.get('wallet'))
    await state.clear()
    await message.answer(text='Поздравляют, твой TON-кошелёк сохранен')

Как только я ввожу адрес кошелька, в терминал выскакивает ошибка, которую я указал в вопросе

Comments

[Сергей Горностаев]

Конструкция db.pool.execute(sql, wallet) выглядит подозрительно. Что такое db? Как создавался этот pool? Почему execute на нём вызывается, а не на полученном из него соединении? Вы там одно соединение между разными сопрограммами не шарите ли?

[Nikita235]

Да, у меня одно соединение между разными сопрограммами, мощный я, конечно. Спасибо за наводку!
Напишите это сообщение в ответах, отмечу решением

Answer 1

[Сергей Горностаев]

Видимо, проблема в том, что вы пытаетесь использовать одно соединение несколькими сопрограммами. Используйте пул.

Comments

[Nikita235]

Вот моя реализация(отдельный файл, для конекта):

import asyncio

import asyncpg
from config_data.config import ConfigDb, load_config_db

config_db: ConfigDb = load_config_db()


class Database:
    def __init__(self, loop: asyncio.AbstractEventLoop):
        self.pool = loop.run_until_complete(
            asyncpg.create_pool(
            host='127.0.0.1',
            user=config_db.database.pg_user,
            password=config_db.database.pg_password,
            database=config_db.database.db_name
            )
        )


loop = asyncio.get_event_loop()
db = Database(loop)

К сожалению, от ошибки это не избавило

[Сергей Горностаев]

Nikita235, а чем должен был помочь отдельный файл? В моëм ответе есть ссылка, там можно посмотреть, как правильно использовать пул.