Method operation

trinity/buffer/storage/sql.py:355–357

(session: AsyncSession)

        await self.prepare()

        async def operation(session: AsyncSession):
            tasks = [self.table_model_cls.from_dict(item) for item in data]
            session.add_all(tasks)

        await async_run_with_retry_session(
            self.session, operation, self.max_retry_times, self.max_retry_interval