wip

tim-smart · tim-smart · commit 32b7d9fb89cd · 2025-11-04T13:20:43.000+13:00
diff --git a/packages/cluster/src/Sharding.ts b/packages/cluster/src/Sharding.ts
@@ -1271,7 +1271,8 @@ const make = Effect.gen(function*() {
       }
 
       yield* PubSub.publish(events, EntityRegistered({ entity }))
-    }
+    },
+    withStorageReadLock
   )
 
   yield* Scope.addFinalizerExit(

Original file line number	Diff line number	Diff line change
`@@ -1271,7 +1271,8 @@ const make = Effect.gen(function*() {`
`1271`	`1271`	`}`
`1272`	`1272`
`1273`	`1273`	`yield* PubSub.publish(events, EntityRegistered({ entity }))`
`1274`		`- }`
	`1274`	`+ },`
	`1275`	`+ withStorageReadLock`
`1275`	`1276`	`)`
`1276`	`1277`
`1277`	`1278`	`yield* Scope.addFinalizerExit(`