Peewee пропускает обновление некоторых моделей - PullRequest
Новая
       9

Peewee пропускает обновление некоторых моделей

0 голосов
/ 17 июня 2020

Мне нужно перенести данные всех игроков из одного столбца в другой, их там около 1 миллиона, но код, который теперь пропускает некоторых пользователей, не обновляя их, скажите, пожалуйста, как это можно сделать более эффективно , мне нужно сделать паузу с любым 1 запросом или любым? 

from database import manager
from database.models import CasinoPlayerOld, CasinoPlayer
from engine import Plugin

pl = Plugin()

@pl.on_start()
async def _():
    all_players = await manager.execute(CasinoPlayerOld.select().where(CasinoPlayerOld.wins >= 1))
    for user in all_players:
        p, _ = await manager.get_or_create(CasinoPlayer, user_id=user.user_id)
          if user.stock:
              p.immersion_items[0] = True
          if user.scanner:
              p.immersion_items[1] = True
          if user.dory:
              p.immersion_items[2] = True

          if user.rassembled:
              p.rocket_stages[0] = True
          if user.state1:
              p.rocket_stages[1] = True
          if user.state2:
              p.rocket_stages[2] = True
          if user.state3:
              p.rocket_stages[3] = True

          await manager.update(p)
...