File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change 44import opentracing .ext .tags as ext
55import socket
66import instana .span as sd
7- import Queue
87import time
98import os
109
10+ import sys
11+ if sys .version_info .major is 2 :
12+ import Queue as queue
13+ else :
14+ import queue
15+
1116
1217class InstanaRecorder (SpanRecorder ):
1318 sensor = None
1419 registered_spans = ("django" , "memcache" , "rpc-client" , "rpc-server" )
1520 entry_kind = ["entry" , "server" , "consumer" ]
1621 exit_kind = ["exit" , "client" , "producer" ]
17- queue = Queue .Queue ()
22+ queue = queue .Queue ()
1823
1924 def __init__ (self , sensor ):
2025 super (InstanaRecorder , self ).__init__ ()
@@ -46,7 +51,7 @@ def queued_spans(self):
4651 while True :
4752 try :
4853 s = self .queue .get (False )
49- except Queue .Empty :
54+ except queue .Empty :
5055 break
5156 else :
5257 spans .append (s )
You can’t perform that action at this time.
0 commit comments