@@ -496,18 +496,23 @@ def initialize_telemetry_client(
496
496
)
497
497
TelemetryClientFactory ._initialize ()
498
498
print (
499
- "\n TelemetryClientFactory initialized: %s" ,
499
+ "\n TelemetryClientFactory initialized: %s" ,
500
500
session_id_hex ,
501
501
flush = True ,
502
502
)
503
503
504
504
if session_id_hex not in TelemetryClientFactory ._clients :
505
+ print (
506
+ "\n Session ID not in clients: %s" ,
507
+ session_id_hex ,
508
+ flush = True ,
509
+ )
505
510
logger .debug (
506
511
"Creating new TelemetryClient for connection %s" ,
507
512
session_id_hex ,
508
513
)
509
514
if telemetry_enabled :
510
- print ("\n Telemetry enabled: %s" , session_id_hex , flush = True )
515
+ print ("\n Telemetry enabled: %s" , session_id_hex , flush = True )
511
516
TelemetryClientFactory ._clients [
512
517
session_id_hex
513
518
] = TelemetryClient (
@@ -518,17 +523,19 @@ def initialize_telemetry_client(
518
523
executor = TelemetryClientFactory ._executor ,
519
524
)
520
525
print (
521
- "\n Telemetry client initialized: %s" ,
526
+ "\n Telemetry client initialized: %s" ,
522
527
session_id_hex ,
523
528
flush = True ,
524
529
)
525
530
else :
526
- print ("\n Telemetry disabled: %s" , session_id_hex , flush = True )
531
+ print (
532
+ "\n Telemetry disabled: %s" , session_id_hex , flush = True
533
+ )
527
534
TelemetryClientFactory ._clients [
528
535
session_id_hex
529
536
] = NoopTelemetryClient ()
530
537
print (
531
- "\n Noop Telemetry client initialized: %s" ,
538
+ "\n Noop Telemetry client initialized: %s" ,
532
539
session_id_hex ,
533
540
flush = True ,
534
541
)
0 commit comments