diff --git a/packages/pglite/examples/worker-process.js b/packages/pglite/examples/worker-process.js
index 585dfa776..9bc36d954 100644
--- a/packages/pglite/examples/worker-process.js
+++ b/packages/pglite/examples/worker-process.js
@@ -5,11 +5,20 @@ import { vector } from '../dist/vector/index.js'
 worker({
   async init() {
     const pg = new PGlite({
+      dataDir: 'idb://my-pgdata',
       extensions: {
         vector,
       },
     })
     // If you want run any specific setup code for the worker process, you can do it here.
+    console.log('Creating table...')
+    await pg.exec(`
+  CREATE EXTENSION IF NOT EXISTS vector;
+  CREATE TABLE IF NOT EXISTS test (
+    id SERIAL PRIMARY KEY,
+    data vector(3)
+  );
+`)    
     return pg
   },
 })
diff --git a/packages/pglite/examples/worker.html b/packages/pglite/examples/worker.html
index c81f28864..faf5bdb06 100644
--- a/packages/pglite/examples/worker.html
+++ b/packages/pglite/examples/worker.html
@@ -45,7 +45,6 @@ <h2>Main Thread</h2>
         <script type="module">
           import { PGliteWorker } from '@electric-sql/pglite/worker'
           import { live } from '@electric-sql/pglite/live'
-
           console.log('Creating worker...')
           const pg = new PGliteWorker(
             new Worker(new URL('./worker-process.js', import.meta.url), {
@@ -64,19 +63,19 @@ <h2>Main Thread</h2>
               const leader = document.getElementById('leader')
               leader.textContent = 'true'
               leader.style.color = 'green'
+
             }
+            console.log('Leader has changed, clearing output ...')
+            output.textContent = ''
+            setTimeout(async () => {
+              console.log('requesting incrementalQuery')
+              let incResult = await pg.live.incrementalQuery(`SELECT * FROM test`, [], 'id', (data) => {
+                const output = document.getElementById('output')
+                output.textContent = JSON.stringify(data.rows, null, 2)
+              })
+          }, 200)
           })
 
-          console.log('Creating table...')
-
-          await pg.exec(`
-  CREATE EXTENSION IF NOT EXISTS vector;
-  CREATE TABLE IF NOT EXISTS test (
-    id SERIAL PRIMARY KEY,
-    data vector(3)
-  );
-`)
-
           console.log('Ready!')
 
           async function insertData() {
@@ -96,11 +95,13 @@ <h2>Main Thread</h2>
           const btnClear = document.querySelector('#clear')
           btnClear.addEventListener('click', clearData)
 
-          // pg.live.query(
-          pg.live.incrementalQuery(`SELECT * FROM test`, [], 'id', (data) => {
-            const output = document.getElementById('output')
-            output.textContent = JSON.stringify(data.rows, null, 2)
-          })
+          setTimeout(async () => {
+            let incResult = await pg.live.incrementalQuery(`SELECT * FROM test`, [], 'id', (data) => {
+              console.log('requesting incrementalQuery')
+              const output = document.getElementById('output')
+              output.textContent = JSON.stringify(data.rows, null, 2)
+            })
+          }, 200)
         </script>
       </div>
       <div id="log"></div>