diff --git a/test/integration/test_python_elasticsearchclient.go b/test/integration/test_python_elasticsearchclient.go index 8b8cf7c9b..625d39665 100644 --- a/test/integration/test_python_elasticsearchclient.go +++ b/test/integration/test_python_elasticsearchclient.go @@ -63,7 +63,7 @@ func assertElasticsearchOperation(t *testing.T, comm, op, queryText, index strin var tq jaeger.TracesQuery require.NoError(t, json.NewDecoder(resp.Body).Decode(&tq)) traces := tq.FindBySpan(jaeger.Tag{Key: "db.operation.name", Type: "string", Value: op}) - require.GreaterOrEqual(t, len(traces), 1) + require.GreaterOrEqual(t, len(traces), 1, resp.Body) lastTrace := traces[len(traces)-1] span := lastTrace.Spans[0] diff --git a/test/integration/traces_test.go b/test/integration/traces_test.go index 7b5a0d91d..07f36de89 100644 --- a/test/integration/traces_test.go +++ b/test/integration/traces_test.go @@ -858,14 +858,12 @@ func ensureTracesMatch(t *testing.T, urlPath string) { traces := tq.FindBySpan(jaeger.Tag{Key: "url.path", Type: "string", Value: "/" + urlPath}) require.LessOrEqual(t, 5, len(traces)) multipleTraces = traces - }, test.Interval(500*time.Millisecond)) - // Ensure all 5 traces have proper full chain Java -> Node - for _, trace := range multipleTraces { - var traceID string + // Ensure all 5 traces have proper full chain Java -> Node + for _, trace := range multipleTraces { + var traceID string - // Check the information of the java parent span with retry - test.Eventually(t, testTimeout, func(t require.TestingT) { + // Check the information of the java parent span with retry res := trace.FindByOperationName("GET /"+urlPath, "server") require.Len(t, res, 1) parent := res[0] @@ -903,8 +901,8 @@ func ensureTracesMatch(t *testing.T, urlPath string) { jaeger.Tag{Key: "span.kind", Type: "string", Value: "server"}, ) assert.Empty(t, sd, sd.String()) - }, test.Interval(30*time.Millisecond)) - } + } + }, test.Interval(500*time.Millisecond)) } func testNestedHTTPSTracesKProbes(t *testing.T) {