code: async def push_transaction_async(self):
          
          await self.connect_async(loop=self.loop)
          depth = self.transaction_depth_async()
          if not depth:
              conn = await self._async_conn.acquire()
              self._task_data.set('conn', conn)
          self._task_data.set('depth', depth + 1)
docs: Increment async transaction depth.