Skip to content

Commit d2ee18c

Browse files
authored
fix: Don't check for existing replicas when starting up (#4587)
This was blocking startup, creating a chicken and egg problem where if a replica died, a single one couldn't be bootstrapped again.
1 parent 2ba4a62 commit d2ee18c

File tree

2 files changed

+0
-25
lines changed

2 files changed

+0
-25
lines changed

enterprise/replicasync/replicasync.go

-8
Original file line numberDiff line numberDiff line change
@@ -93,14 +93,6 @@ func New(ctx context.Context, logger slog.Logger, db database.Store, pubsub data
9393
if err != nil {
9494
return nil, xerrors.Errorf("run replica: %w", err)
9595
}
96-
peers := manager.Regional()
97-
if len(peers) > 0 {
98-
self := manager.Self()
99-
if self.RelayAddress == "" {
100-
return nil, xerrors.Errorf("a relay address must be specified when running multiple replicas in the same region")
101-
}
102-
}
103-
10496
err = manager.subscribe(ctx)
10597
if err != nil {
10698
return nil, xerrors.Errorf("subscribe: %w", err)

enterprise/replicasync/replicasync_test.go

-17
Original file line numberDiff line numberDiff line change
@@ -44,23 +44,6 @@ func TestReplica(t *testing.T) {
4444
_ = server.Close()
4545
require.NoError(t, err)
4646
})
47-
t.Run("ErrorsWithoutRelayAddress", func(t *testing.T) {
48-
// Ensures that the replica reports a successful status for
49-
// accessing all of its peers.
50-
t.Parallel()
51-
db, pubsub := dbtestutil.NewDB(t)
52-
_, err := db.InsertReplica(context.Background(), database.InsertReplicaParams{
53-
ID: uuid.New(),
54-
CreatedAt: database.Now(),
55-
StartedAt: database.Now(),
56-
UpdatedAt: database.Now(),
57-
Hostname: "something",
58-
})
59-
require.NoError(t, err)
60-
_, err = replicasync.New(context.Background(), slogtest.Make(t, nil), db, pubsub, nil)
61-
require.Error(t, err)
62-
require.Equal(t, "a relay address must be specified when running multiple replicas in the same region", err.Error())
63-
})
6447
t.Run("ConnectsToPeerReplica", func(t *testing.T) {
6548
// Ensures that the replica reports a successful status for
6649
// accessing all of its peers.

0 commit comments

Comments
 (0)