Skip to content

Commit

Permalink
Awaiter shouldn't bail if no checkpoint has been published yet
Browse files Browse the repository at this point in the history
  • Loading branch information
AlCutter committed Dec 9, 2024
1 parent f7531e4 commit ddfd17c
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion await.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,9 @@ package tessera

import (
"context"
"errors"
"fmt"
"os"
"sync"
"time"

Expand Down Expand Up @@ -111,7 +113,7 @@ func (a *IntegrationAwaiter) pollLoop(ctx context.Context, readCheckpoint func(c
// Note that for now, this releases all clients in the event of a single failure.
// If this causes problems, this could be changed to attempt retries.
rawCp, err := readCheckpoint(ctx)
if err != nil {
if err != nil && !errors.Is(err, os.ErrNotExist) {
a.releaseClientsErr(fmt.Errorf("readCheckpoint: %v", err))
continue
}
Expand Down

0 comments on commit ddfd17c

Please sign in to comment.