|  | @@ -77,7 +77,6 @@ class AgentService:
 | 
											
												
													
														|  |          self.scheduler_mode = self.config.get('system', {}).get('scheduler_mode', 'local')
 |  |          self.scheduler_mode = self.config.get('system', {}).get('scheduler_mode', 'local')
 | 
											
												
													
														|  |          self.scheduler_queue = None
 |  |          self.scheduler_queue = None
 | 
											
												
													
														|  |          self.msg_scheduler_thread = None
 |  |          self.msg_scheduler_thread = None
 | 
											
												
													
														|  | -        self.limit_initiative_conversation_rate = True
 |  | 
 | 
											
												
													
														|  |          self.running = False
 |  |          self.running = False
 | 
											
												
													
														|  |          self.process_thread = None
 |  |          self.process_thread = None
 | 
											
												
													
														|  |          self._sigint_cnt = 0
 |  |          self._sigint_cnt = 0
 | 
											
										
											
												
													
														|  | @@ -325,8 +324,6 @@ class AgentService:
 | 
											
												
													
														|  |                          else:
 |  |                          else:
 | 
											
												
													
														|  |                              message_type = MessageType.TEXT
 |  |                              message_type = MessageType.TEXT
 | 
											
												
													
														|  |                          self._send_response(staff_id, user_id, resp, message_type, skip_check=True)
 |  |                          self._send_response(staff_id, user_id, resp, message_type, skip_check=True)
 | 
											
												
													
														|  | -                        if self.limit_initiative_conversation_rate:
 |  | 
 | 
											
												
													
														|  | -                            time.sleep(random.randint(10,20))
 |  | 
 | 
											
												
													
														|  |                      agent.persist_state()
 |  |                      agent.persist_state()
 | 
											
												
													
														|  |                  except Exception as e:
 |  |                  except Exception as e:
 | 
											
												
													
														|  |                      # FIXME:虽然需要主动唤起的用户同时发来消息的概率很低,但仍可能会有并发冲突
 |  |                      # FIXME:虽然需要主动唤起的用户同时发来消息的概率很低,但仍可能会有并发冲突
 |