opensource/grafana
1
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-08-02 05:10:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(test): Attempt to make TestPollingNotifier/notify_returns_channel_and_starts_polling less flaky (#103947)

Browse Source 
Signed-off-by: Dave Henderson <dave.henderson@grafana.com>
This commit is contained in:
Dave Henderson
2025-04-14 03:41:09 -04:00
committed by GitHub
parent 90f82cf1af
commit 1125f36f4f
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/storage/unified/sql/notifier_sql_test.go
View File

@ -2,13 +2,14 @@ package sql
import (
"context"
"sync"
"testing"
"time"
"github.com/grafana/grafana-app-sdk/logging"
"github.com/stretchr/testify/require"
"go.opentelemetry.io/otel/trace/noop"
"github.com/grafana/grafana-app-sdk/logging"
"github.com/grafana/grafana/pkg/storage/unified/resource"
"github.com/grafana/grafana/pkg/storage/unified/sql/sqltemplate"
)
@ -231,11 +232,16 @@ func TestPollingNotifier(t *testing.T) {
}
var historyPollCalled bool
once := sync.Once{}
historyPoll := func(ctx context.Context, grp string, res string, since int64) ([]*historyPollResponse, error) {
historyPollCalled = true
require.Equal(t, "test-group", grp)
require.Equal(t, "test-resource", res)
require.Equal(t, int64(0), since)
// only assert the first time - this may be called multiple times
// depending on the host hardware etc, due to timing issues...
once.Do(func() {
historyPollCalled = true
require.Equal(t, "test-group", grp)
require.Equal(t, "test-resource", res)
require.Equal(t, int64(0), since)
})
return []*historyPollResponse{testEvent}, nil
}