Skip to content

Commit

Permalink
Update test
Browse files Browse the repository at this point in the history
  • Loading branch information
ritalwar committed Oct 30, 2023
1 parent b2cb507 commit 74eb3ae
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions x-pack/metricbeat/module/airflow/statsd/data_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ import (
_ "github.com/elastic/beats/v7/libbeat/processors/actions"
"github.com/elastic/beats/v7/metricbeat/mb"
mbtest "github.com/elastic/beats/v7/metricbeat/mb/testing"
_ "github.com/elastic/beats/v7/x-pack/metricbeat/module/statsd/server"

Check failure on line 23 in x-pack/metricbeat/module/airflow/statsd/data_test.go

View workflow job for this annotation

GitHub Actions / lint (windows)

ST1019(related information): other import of "github.com/elastic/beats/v7/x-pack/metricbeat/module/statsd/server" (stylecheck)

Check failure on line 23 in x-pack/metricbeat/module/airflow/statsd/data_test.go

View workflow job for this annotation

GitHub Actions / lint (linux)

ST1019(related information): other import of "github.com/elastic/beats/v7/x-pack/metricbeat/module/statsd/server" (stylecheck)
)

func init() {
Expand Down Expand Up @@ -77,11 +78,9 @@ func TestData(t *testing.T) {

wg.Wait()
createEvent("dagrun.duration.failed.a_dagid:200|ms|#k1:v1,k2:v2", t)
createEvent("dagrun.duration.failed.b_dagid:500|ms|#k3:v3,k4:v4", t)
createEvent("dagrun.duration.failed.b_dagid:500|ms|#k1:v1,k2:v2", t)
<-done

assert.Len(t, events, 2)

if len(events) == 0 {
t.Fatal("received no events")
}
Expand Down

0 comments on commit 74eb3ae

Please sign in to comment.