From 7b9dbe56f8f2aaca2291b4b532aea020418a7008 Mon Sep 17 00:00:00 2001 From: Alexey Palazhchenko Date: Mon, 23 Dec 2024 17:48:36 +0400 Subject: [PATCH] Add TODOs Refs #1122. --- cmd/dance/main.go | 1 + internal/pusher/pusher.go | 4 ++++ 2 files changed, 5 insertions(+) diff --git a/cmd/dance/main.go b/cmd/dance/main.go index 890e15d1..86789811 100644 --- a/cmd/dance/main.go +++ b/cmd/dance/main.go @@ -282,6 +282,7 @@ func main() { } if pusherClient != nil { + // TODO https://github.com/FerretDB/dance/issues/1122 if err = pusherClient.Push(ctx, cf, db, cmp.Passed); err != nil { log.Fatal(err) } diff --git a/internal/pusher/pusher.go b/internal/pusher/pusher.go index 48b68e20..3d83dcbf 100644 --- a/internal/pusher/pusher.go +++ b/internal/pusher/pusher.go @@ -103,6 +103,8 @@ func New(uri string, l *slog.Logger) (*Client, error) { } // ping pings the database until connection is established or ctx is canceled. +// +// TODO https://github.com/FerretDB/dance/issues/1122 func (c *Client) ping(ctx context.Context) { for ctx.Err() == nil { pingCtx, pingCancel := context.WithTimeout(ctx, 5*time.Second) @@ -154,6 +156,8 @@ func (c *Client) Push(ctx context.Context, config, database string, res map[stri } // Close closes all connections. +// +// TODO https://github.com/FerretDB/dance/issues/1122 func (c *Client) Close() { c.pingerCancel() <-c.pingerDone