coder
diff --git a/‎coderd/database/migrations/testdata/fixtures/000155_pg_coordinator_single_tailnet.up.sql renamed to ‎coderd/database/migrations/testdata/fixtures/000156_pg_coordinator_single_tailnet.up.sql b/‎coderd/database/migrations/testdata/fixtures/000155_pg_coordinator_single_tailnet.up.sql renamed to ‎coderd/database/migrations/testdata/fixtures/000156_pg_coordinator_single_tailnet.up.sql
diff --git a/‎enterprise/tailnet/pgcoord.go
Lines changed: 5 additions & 10 deletions b/‎enterprise/tailnet/pgcoord.go
Lines changed: 5 additions & 10 deletions
@@ -251,16 +251,6 @@ func (c *pgCoord) ServeClient(conn net.Conn, id uuid.UUID, agent uuid.UUID) erro
 	if err := c.addSubscription(cIO, agent); err != nil {
 		return err
 	}
-	defer func() {
-		err := c.removeSubscription(cIO, agent)
-		if err != nil {
-			c.logger.Debug(c.ctx, "remove client subscription",
-				slog.F("client_id", id),
-				slog.F("agent_id", agent),
-				slog.Error(err),
-			)
-		}
-	}()
 
 	<-cIO.ctx.Done()
 	return nil
@@ -924,12 +914,15 @@ func (q *querier) newClientSubscription(c agpl.Queue, agentID uuid.UUID) {
 		q.clientSubscriptions[c.UniqueID()] = map[uuid.UUID]struct{}{}
 	}
 
+	fmt.Println("add sub", c.UniqueID(), agentID)
+
 	mk := mKey{
 		agent: agentID,
 		kind:  agpl.QueueKindClient,
 	}
 	cm, ok := q.mappers[mk]
 	if !ok {
+		fmt.Println("new mapper")
 		ctx, cancel := context.WithCancel(q.ctx)
 		mpr := newMapper(ctx, q.logger, mk, q.heartbeats)
 		cm = &countedMapper{
@@ -952,6 +945,8 @@ func (q *querier) removeClientSubscription(c agpl.Queue, agentID uuid.UUID) {
 	q.mu.Lock()
 	defer q.mu.Unlock()
 
+	fmt.Println("remove sub", c.UniqueID(), agentID)
+
 	// agentID: uuid.Nil indicates that a client is going away. The querier
 	// handles that in cleanupConn below instead.
 	if agentID == uuid.Nil {