Try to get concurrency working

pyth-network · Aug 14, 2024 · 16c64c6 · 16c64c6
1 parent ee1beff
commit 16c64c6
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/program_admin/__init__.py b/program_admin/__init__.py
@@ -261,7 +261,7 @@ async def sync(
 
         # Sync product/price accounts
 
-        transactions: list[Coroutine[Any, Any, None]] = []
+        transactions: List[asyncio.Task[None]] = []
 
         product_updates: bool = False
 
@@ -282,7 +282,9 @@ async def sync(
                 instructions.extend(product_instructions)
                 if send_transactions:
                     transactions.append(
-                        self.send_transaction(product_instructions, product_keypairs)
+                        asyncio.create_task(
+                            self.send_transaction(product_instructions, product_keypairs)
+                        )
                     )
 
         await asyncio.gather(*transactions)
@@ -308,7 +310,9 @@ async def sync(
                 instructions.extend(price_instructions)
                 if send_transactions:
                     transactions.append(
-                        self.send_transaction(price_instructions, price_keypairs)
+                        asyncio.create_task(
+                            self.send_transaction(price_instructions, price_keypairs)
+                        )
                     )
 
         await asyncio.gather(*transactions)