@@ -180,16 +180,16 @@ class BulkTransactionsClient(AsyncBaseBulkTransactionsClient):
180
180
"""Postgres bulk transactions."""
181
181
182
182
async def bulk_item_insert (
183
- self , items : Items , request : Request , method : BulkTransactionMethod , ** kwargs
183
+ self , items : Items , request : Request , ** kwargs
184
184
) -> str :
185
185
"""Bulk item insertion using pgstac."""
186
- items = list (items .items .values ())
186
+ items_to_insert = list (items .items .values ())
187
187
188
188
async with request .app .state .get_connection (request , "w" ) as conn :
189
- if method == BulkTransactionMethod .INSERT :
190
- await dbfunc (conn , "create_items" , items )
191
- elif method == BulkTransactionMethod .UPSERT :
192
- await dbfunc (conn , "upsert_items" , items )
189
+ if items . method == BulkTransactionMethod .INSERT :
190
+ await dbfunc (conn , "create_items" , items_to_insert )
191
+ elif items . method == BulkTransactionMethod .UPSERT :
192
+ await dbfunc (conn , "upsert_items" , items_to_insert )
193
193
194
- return_msg = f"Successfully added { len (items )} items."
194
+ return_msg = f"Successfully added { len (items_to_insert )} items."
195
195
return return_msg
0 commit comments