File tree Expand file tree Collapse file tree 1 file changed +12
-9
lines changed
dd-trace-core/src/main/java/datadog/trace/common/writer Expand file tree Collapse file tree 1 file changed +12
-9
lines changed Original file line number Diff line number Diff line change 55import static java .util .concurrent .TimeUnit .SECONDS ;
66
77import datadog .trace .core .DDSpan ;
8- import datadog .trace .core .MetadataConsumer ;
98import java .util .List ;
109import java .util .concurrent .CopyOnWriteArrayList ;
1110import java .util .concurrent .TimeUnit ;
@@ -38,14 +37,18 @@ public void write(List<DDSpan> trace) {
3837 for (DDSpan span : trace ) {
3938 // This is needed to properly do all delayed processing to make this writer even
4039 // remotely realistic so the test actually test something
41- span .processTagsAndBaggage (metadata -> {
42- // surface injected baggage metadata as span tags so they can be asserted
43- metadata .getBaggage ().forEach ((k , v ) -> {
44- if (!k .startsWith ("_dd." ) && span .getTag (k ) == null ) {
45- span .setTag (k , v );
46- }
47- });
48- });
40+ span .processTagsAndBaggage (
41+ metadata -> {
42+ // surface injected baggage metadata as span tags so they can be asserted
43+ metadata
44+ .getBaggage ()
45+ .forEach (
46+ (k , v ) -> {
47+ if (!k .startsWith ("_dd." ) && span .getTag (k ) == null ) {
48+ span .setTag (k , v );
49+ }
50+ });
51+ });
4952 }
5053
5154 add (trace );
You can’t perform that action at this time.
0 commit comments