Use storage.execute to write data

rabotnikobm/rules/get_building.py

@@ -41,7 +41,6 @@ class GetBuilding(Rule):
         ):
 
             # Push the building data to storage_to
-            async with self.storage_to.connection.cursor() as cur:
-                await cur.execute(
-                    "INSERT INTO obm_buildings (osm_id, geometry) VALUES (%s,%s)", row
-                )
+            await self.storage_to.execute(
+                "INSERT INTO obm_buildings (osm_id, geometry) VALUES (%s,%s)", row
+            )