From ddfd17ced3f857547e89506ef01c4ba7867ef84e Mon Sep 17 00:00:00 2001 From: Al Cutter Date: Fri, 6 Dec 2024 16:09:24 +0000 Subject: [PATCH] Awaiter shouldn't bail if no checkpoint has been published yet --- await.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/await.go b/await.go index 8f0b6c55..59f08c18 100644 --- a/await.go +++ b/await.go @@ -16,7 +16,9 @@ package tessera import ( "context" + "errors" "fmt" + "os" "sync" "time" @@ -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 }