diff --git a/src/ws/tell_cluster_to_identify.ts b/src/ws/tell_cluster_to_identify.ts index f89721c48..518724994 100644 --- a/src/ws/tell_cluster_to_identify.ts +++ b/src/ws/tell_cluster_to_identify.ts @@ -1,4 +1,3 @@ -import { closeWS } from "./close_ws.ts"; import { ws } from "./ws.ts"; /** Allows users to hook in and change to communicate to different clusters across different servers or anything they like. For example using redis pubsub to talk to other servers. */ @@ -7,11 +6,5 @@ export async function tellClusterToIdentify( shardId: number, _bucketId: number, ) { - // When resharding this may exist already - const oldShard = ws.shards.get(shardId); await ws.identify(shardId, ws.maxShards); - - if (oldShard) { - closeWS(oldShard.ws, 3063, "Resharded!"); - } }