File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -883,7 +883,7 @@ def start_thread(self, json_body):
883883
884884 def is_finished (self ):
885885 with self .lock :
886- return self .thread and not self .thread .isAlive () and self .finished and len (self .messages ) == 0
886+ return self .thread and not self .thread .is_alive () and self .finished and len (self .messages ) == 0
887887
888888 def process_messages (self , channel , rabbitmq_queue ):
889889 while self .messages :
Original file line number Diff line number Diff line change @@ -143,7 +143,7 @@ def start(self):
143143 for key , value in self .extractor_info ['process' ].items ():
144144 for mt in value :
145145 # Replace trailing '*' with '#'
146- mt = re .sub ('(\*$)' , '#' , mt )
146+ mt = re .sub (r '(\*$)' , '#' , mt )
147147 if mt .find ('*' ) > - 1 :
148148 logger .error ("Invalid '*' found in rabbitmq_key: %s" % mt )
149149 else :
You can’t perform that action at this time.
0 commit comments