From 566851ea5af2b231b7ee21809f6fe09de697eeee Mon Sep 17 00:00:00 2001 From: Annanay Date: Fri, 19 Oct 2018 22:29:37 +0530 Subject: [PATCH] [Storage] Fix childspan context while tracing cassandra queries Signed-off-by: Annanay --- plugin/storage/cassandra/spanstore/reader.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/plugin/storage/cassandra/spanstore/reader.go b/plugin/storage/cassandra/spanstore/reader.go index 7b751c51ca0f..33bdbe5f6b06 100644 --- a/plugin/storage/cassandra/spanstore/reader.go +++ b/plugin/storage/cassandra/spanstore/reader.go @@ -291,7 +291,7 @@ func (s *SpanReader) queryByTagsAndLogs(ctx context.Context, tq *spanstore.Trace results := make([]dbmodel.UniqueTraceIDs, 0, len(tq.Tags)) for k, v := range tq.Tags { - childSpan := opentracing.StartSpan("queryByTag") + childSpan, _ := opentracing.StartSpanFromContext(ctx, "queryByTag") childSpan.LogFields(otlog.String("tag.key", k), otlog.String("tag.value", v)) query := s.session.Query( queryByTag, @@ -330,7 +330,7 @@ func (s *SpanReader) queryByDuration(ctx context.Context, traceQuery *spanstore. endTimeByHour := traceQuery.StartTimeMax.Round(durationBucketSize) for timeBucket := endTimeByHour; timeBucket.After(startTimeByHour) || timeBucket.Equal(startTimeByHour); timeBucket = timeBucket.Add(-1 * durationBucketSize) { - childSpan := opentracing.StartSpan("queryForTimeBucket") + childSpan, _ := opentracing.StartSpanFromContext(ctx, "queryForTimeBucket") childSpan.LogFields(otlog.String("timeBucket", timeBucket.String())) query := s.session.Query( queryByDuration,