@@ -130,7 +130,7 @@ async def updates(request):
130130 num_queries = get_num_queries (request )
131131 update_ids = sample (range (1 , 10001 ), num_queries )
132132 update_ids .sort ()
133- updates = zip (updates , sample (range (1 , 10001 ), num_queries ))
133+ updates = zip (update_ids , sample (range (1 , 10001 ), num_queries ))
134134 worlds = [{'id' : row_id , 'randomNumber' : number } for row_id , number in updates ]
135135
136136 async with request .app ['db_session' ].begin () as sess :
@@ -146,12 +146,12 @@ async def updates_raw(request):
146146 num_queries = get_num_queries (request )
147147 update_ids = sample (range (1 , 10001 ), num_queries )
148148 update_ids .sort ()
149- updates = zip (updates , sample (range (1 , 10001 ), num_queries ))
149+ updates = zip (update_ids , sample (range (1 , 10001 ), num_queries ))
150150 worlds = [{'id' : row_id , 'randomNumber' : number } for row_id , number in updates ]
151151
152152 async with request .app ['pg' ].acquire () as conn :
153153 stmt = await conn .prepare (READ_ROW_SQL )
154- for id_ in updates :
154+ for id_ , _ in updates :
155155 # the result of this is the int previous random number which we don't actually use
156156 await stmt .fetchval (id_ )
157157 await conn .executemany (WRITE_ROW_SQL , updates )
0 commit comments