@@ -655,14 +655,14 @@ describe('instrumentation-kafkajs', () => {
655655 const spans = getTestSpans ( ) ;
656656 const transactionSpan = spans . find ( s => s . name === 'transaction' ) ;
657657 const sendSpans = spans . filter ( s => s . name === 'send topic-name-1' ) ;
658- assert . ok ( transactionSpan )
658+ assert . ok ( transactionSpan ) ;
659659 assert . strictEqual ( spans . length , 3 ) ;
660660 assert . strictEqual ( transactionSpan . kind , SpanKind . INTERNAL ) ;
661661 assert . strictEqual ( transactionSpan . status . code , SpanStatusCode . UNSET ) ;
662662
663663 assert . strictEqual ( sendSpans . length , 2 ) ;
664- assert . strictEqual ( sendSpans [ 0 ] . name , 'send topic-name-1' )
665- assert . strictEqual ( sendSpans [ 1 ] . name , 'send topic-name-1' )
664+ assert . strictEqual ( sendSpans [ 0 ] . name , 'send topic-name-1' ) ;
665+ assert . strictEqual ( sendSpans [ 1 ] . name , 'send topic-name-1' ) ;
666666 await assertSuccessfulSendSpans ( {
667667 spans : sendSpans ,
668668 metricReader,
@@ -700,8 +700,8 @@ describe('instrumentation-kafkajs', () => {
700700 const spans = getTestSpans ( ) ;
701701 const transactionSpan = spans . find ( s => s . name === 'transaction' ) ;
702702 const sendSpan = spans . find ( s => s . name . startsWith ( 'send' ) ) ;
703- assert . ok ( transactionSpan )
704- assert . ok ( sendSpan )
703+ assert . ok ( transactionSpan ) ;
704+ assert . ok ( sendSpan ) ;
705705 assert . strictEqual ( transactionSpan . kind , SpanKind . INTERNAL ) ;
706706 assertSpanHasParent ( transactionSpan , sendSpan ) ;
707707 assert . strictEqual ( transactionSpan . status . code , SpanStatusCode . ERROR ) ;
@@ -710,7 +710,7 @@ describe('instrumentation-kafkajs', () => {
710710 'error thrown from kafka client transaction commit'
711711 ) ;
712712 assert . strictEqual ( sendSpan . status . code , SpanStatusCode . UNSET ) ;
713- assert . strictEqual ( sendSpan . name , 'send topic-name-1' )
713+ assert . strictEqual ( sendSpan . name , 'send topic-name-1' ) ;
714714 expectKafkaHeadersToMatchSpanContext (
715715 messagesSent [ 0 ] ,
716716 sendSpan as ReadableSpan
@@ -732,8 +732,8 @@ describe('instrumentation-kafkajs', () => {
732732 spans . find ( s => s . name === 'transaction' ) ,
733733 spans . find ( s => s . name === 'send topic-name-1' ) ,
734734 ] ;
735- assert . ok ( transactionSpan )
736- assert . ok ( sendSpan )
735+ assert . ok ( transactionSpan ) ;
736+ assert . ok ( sendSpan ) ;
737737 assertSpanHasParent ( transactionSpan , sendSpan ) ;
738738 expectKafkaHeadersToMatchSpanContext (
739739 messagesSent [ 0 ] ,
@@ -764,8 +764,8 @@ describe('instrumentation-kafkajs', () => {
764764 spans . find ( s => s . name === 'transaction' ) ,
765765 spans . find ( s => s . name . startsWith ( 'send' ) ) ,
766766 ] ;
767- assert . ok ( transactionSpan )
768- assert . ok ( sendSpan )
767+ assert . ok ( transactionSpan ) ;
768+ assert . ok ( sendSpan ) ;
769769 assertSpanHasParent ( transactionSpan , sendSpan ) ;
770770 assert . strictEqual ( transactionSpan . kind , SpanKind . INTERNAL ) ;
771771 assert . strictEqual ( transactionSpan . status . code , SpanStatusCode . ERROR ) ;
@@ -798,8 +798,8 @@ describe('instrumentation-kafkajs', () => {
798798 const spans = getTestSpans ( ) ;
799799 const transactionSpan = spans . find ( s => s . name === 'transaction' ) ;
800800 const sendSpans = spans . filter ( s => s . name . startsWith ( 'send' ) ) ;
801- assert . ok ( transactionSpan )
802- assert . ok ( sendSpans )
801+ assert . ok ( transactionSpan ) ;
802+ assert . ok ( sendSpans ) ;
803803 sendSpans . forEach ( s => assertSpanHasParent ( transactionSpan , s ) ) ;
804804 assert . ok ( haveSameTraceId ( spans ) ) ;
805805 } ) ;
@@ -819,8 +819,8 @@ describe('instrumentation-kafkajs', () => {
819819 const spans = getTestSpans ( ) ;
820820 const transactionSpan = spans . find ( s => s . name === 'transaction' ) ;
821821 const sendSpans = spans . filter ( s => s . name . startsWith ( 'send' ) ) ;
822- assert . ok ( transactionSpan )
823- assert . strictEqual ( sendSpans . length , 3 )
822+ assert . ok ( transactionSpan ) ;
823+ assert . strictEqual ( sendSpans . length , 3 ) ;
824824 assert . strictEqual ( spans [ 0 ] . name , 'send topic-name-1' ) ;
825825 assert . strictEqual ( spans [ 1 ] . name , 'send topic-name-1' ) ;
826826 assert . strictEqual ( spans [ 2 ] . name , 'send topic-name-2' ) ;
@@ -860,8 +860,8 @@ describe('instrumentation-kafkajs', () => {
860860 spans . find ( s => s . name === 'transaction' ) ,
861861 spans . find ( s => s . name === 'send topic-name-1' ) ,
862862 ] ;
863- assert . ok ( transactionSpan )
864- assert . ok ( sendSpan )
863+ assert . ok ( transactionSpan ) ;
864+ assert . ok ( sendSpan ) ;
865865 const errorMessage =
866866 'error thrown from kafka client transaction send' ;
867867 assertSpanHasParent ( transactionSpan , sendSpan ) ;
@@ -895,8 +895,8 @@ describe('instrumentation-kafkajs', () => {
895895 const spans = getTestSpans ( ) ;
896896 const transactionSpan = spans . find ( s => s . name === 'transaction' ) ;
897897 const sendSpans = spans . filter ( s => s . name === 'send topic-name-1' ) ;
898- assert . ok ( transactionSpan )
899- assert . ok ( sendSpans )
898+ assert . ok ( transactionSpan ) ;
899+ assert . ok ( sendSpans ) ;
900900 await assertFailedSendSpans ( {
901901 spans : sendSpans ,
902902 metricReader,
0 commit comments