Tengo la siguiente relación de uno a muchos en SQLAlchemy.

modelos/usuario.py

 class User(Base): id = Column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4) created_date = Column(DateTime, default=datetime.datetime.utcnow, index=True) name = Column(String) phone = Column(String, index=True) email = Column(String, index=True) status = Column("status", Enum(Status)) orders: List[Order] = relationship("Order", back_populates="users")

modelos/pedido.py

 class Order(Base): id = Column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4) created_date = Column(DateTime, default=datetime.datetime.utcnow, index=True) fullfiled_date = Column(DateTime, index=True) size = Column(String) flavour = Column(String) topping = Column(String) frosting = Column(String) price = Column(Float, index=True) user_id = Column(UUID(as_uuid=True), ForeignKey("user.id"), default=uuid.uuid4) users = relationship("User", back_populates="orders")

capa_acceso_datos

 class UserDAL: def __init__(self, db_session: Session): self.db_session = db_session async def fetch_user_by_email(self, email: str): user = await self.db_session.execute(select(User).filter(User.email == email)) return user.scalar_one_or_none() async def record_order(self, u: Customer, c: Cake, price: float): user = await self.fetch_user_by_email(u.email) if not user: user = User(name=u.name, email=u.email) self.db_session.add(user) await self.db_session.flush() order = Order( size=c.size, flavour=c.flavour, frosting=c.frosting, topping=c.topping, price=price, ) orders = await self.db_session.execute( select(Order).where(Order.user_id.in_(user.orders)) ) for o in orders.scalars.all(): user.orders.append(o) await self.db_session.commit() return order

Para poner la relación en palabras, "un usuario puede tener múltiples pedidos y los pedidos pueden estar asociados a un solo usuario".

Estoy tratando de asociar el pedido del usuario en el campo de pedidos, que es una relación con el modelo de pedido como se define anteriormente. Ahora mismo estoy recibiendo este error:

 sqlalchemy.exc.MissingGreenlet: greenlet_spawn has not been called; can't call await_() here. Was IO attempted in an unexpected place?

¿Cómo puedo asociar al usuario con los pedidos correctamente de forma asíncrona?