Cannot perform operation: another operation is in progress #728

Activity

1. uriyyo commented on Nov 5, 2020

   

   uriyyo

   on Nov 5, 2020

   Contributor

   More actions

   @erhosen I faced the same problem, solution was to use a separate db connection:

   @pytest.fixture
   async def special_model():
       async with db.acquire():  # use seperate db connection
           special_model = await SpecialModel.create(
               internal_name='internal_name',
               comment='comment',
               is_active=True,
               title="Title",
               text="Text"
           )
   
       yield special_model

   This isn't an issue with gino it's an asyncpg issue. Basically, asyncpg can't make two concurrent queries using the same db connection.

   👍React with 👍1Reacted by Fantix King
2. fantix commented on Dec 7, 2020

   

   fantix

   on Dec 7, 2020

   Member

   More actions

   Thanks! This deserves a page in the docs.
3. kgantsov commented on Nov 18, 2021

   

   kgantsov

   on Nov 18, 2021

   More actions

   I have the same exception asyncpg.exceptions._base.InterfaceError: cannot perform operation: another operation is in progress when I run pytest.

   Any idea what I did wrong? I would appreciate any help. Thanks in advance.

   requirements.txt

   fastapi==0.70.0
   gino==1.0.1
   pytest==6.2.5
   pytest-asyncio==0.16.0
   requests==2.26.0
   

   test_code.py

   import os
   from typing import List
   import pytest
   
   from gino import Gino
   from fastapi import APIRouter
   from pydantic import BaseModel
   from fastapi import FastAPI
   from starlette.testclient import TestClient
   
   router = APIRouter()
   
   db = Gino()
   
   
   async def init_db():
       await db.set_bind(os.environ['DATABASE_URL'])
       await db.gino.create_all()
   
   
   class UserModel(db.Model):
       __tablename__ = 'user'
   
       id = db.Column(db.Integer(), primary_key=True)
       name = db.Column(db.Unicode())
       email = db.Column(db.Unicode(), unique=True, index=True)
       password_hash = db.Column(db.Unicode())
   
   
   class UserSchema(BaseModel):
       id: int = 0
       name: str
       email: str
       password: str
   
   
   class UserListSchema(BaseModel):
       objects: List[UserSchema]
   
   
   @router.get("/users/", response_model=UserListSchema)
   async def get_users():
       async with db.acquire():
           users = await UserModel.query.limit(200).gino.all()
   
       return UserListSchema.parse_obj({
           'objects': [x.to_dict() for x in users]
       })
   
   
   def get_app():
       print('INIT APP')
       app = FastAPI(title="GINO FastAPI Demo")
   
       app.include_router(router, prefix='/API/v1')
   
       @app.on_event("startup")
       async def startup_event():
           print('Initialising DB')
           await init_db()
           print('DB was initialised')
   
       return app
   
   
   @pytest.fixture
   def client():
   
       with TestClient(get_app()) as client:
           yield client
   
   
   @pytest.fixture
   @pytest.mark.anyio
   async def user(client):
   
       print('[-------->')
       # await init_db()
   
       # async with db.acquire():
       user = await UserModel.create(email='test@gmail.com')
   
       # async with db.acquire():
       users = await UserModel.query.limit(200).gino.all()
       print('.....=', user)
       print('....._', users)
   
       yield user
   
   
   def test_users(user, client):
       response = client.get(
           "/API/v1/users",
           headers={},
       )
       print('=====', user, response.text)
   
       assert response.status_code == 200
       assert response.json() == {}

   👍React with 👍2Reacted by Sem and PavelBerkut
4. MarkParker5 commented on Aug 25, 2022

   

   MarkParker5

   on Aug 25, 2022

   More actions

   I fixed it by setting poolclass=NullPool in create_async_engine