Skip to content

Commit 566851e

Browse files
author
Annanay
committed
[Storage] Fix childspan context while tracing cassandra queries
Signed-off-by: Annanay <agarwal.ansh@yahoo.co.in>
1 parent 7d9d212 commit 566851e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

plugin/storage/cassandra/spanstore/reader.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -291,7 +291,7 @@ func (s *SpanReader) queryByTagsAndLogs(ctx context.Context, tq *spanstore.Trace
291291

292292
results := make([]dbmodel.UniqueTraceIDs, 0, len(tq.Tags))
293293
for k, v := range tq.Tags {
294-
childSpan := opentracing.StartSpan("queryByTag")
294+
childSpan, _ := opentracing.StartSpanFromContext(ctx, "queryByTag")
295295
childSpan.LogFields(otlog.String("tag.key", k), otlog.String("tag.value", v))
296296
query := s.session.Query(
297297
queryByTag,
@@ -330,7 +330,7 @@ func (s *SpanReader) queryByDuration(ctx context.Context, traceQuery *spanstore.
330330
endTimeByHour := traceQuery.StartTimeMax.Round(durationBucketSize)
331331

332332
for timeBucket := endTimeByHour; timeBucket.After(startTimeByHour) || timeBucket.Equal(startTimeByHour); timeBucket = timeBucket.Add(-1 * durationBucketSize) {
333-
childSpan := opentracing.StartSpan("queryForTimeBucket")
333+
childSpan, _ := opentracing.StartSpanFromContext(ctx, "queryForTimeBucket")
334334
childSpan.LogFields(otlog.String("timeBucket", timeBucket.String()))
335335
query := s.session.Query(
336336
queryByDuration,

0 commit comments

Comments
 (0)