ugh, async

Author: glasnt

alloydb/notebooks/embeddings_batch_processing.ipynb

@@ -600,7 +600,8 @@
     "        await db_conn.commit()\n",
     "\n",
     "        for row in result:\n",
-    "            logger.info(row)\n",
+    "            logger.debug(f\"yielded row: {row._mapping['id']}\")\n",
+    "            yield row._mapping\n",
     "await debug_sql(pool)\n",
     "logger.info(\"Done.\")\n"
    ]