| skipped 118 lines |
119 | 119 | | |
120 | 120 | | async def _run(self, tasks: QueriesDraft): |
121 | 121 | | self.results = [] |
122 | | - | workers = [asyncio.create_task(self.worker()) |
| 122 | + | |
| 123 | + | if sys.version_info.minor > 6: |
| 124 | + | create_task = asyncio.create_task |
| 125 | + | else: |
| 126 | + | loop = asyncio.get_event_loop() |
| 127 | + | create_task = loop.create_task |
| 128 | + | |
| 129 | + | workers = [create_task(self.worker()) |
123 | 130 | | for _ in range(self.workers_count)] |
124 | 131 | | task_list = list(tasks) |
125 | 132 | | self.progress = self.progress_func(total=len(task_list)) |
| skipped 584 lines |