Small refactoring

zhouhuafork · Nov 11, 2019 · 5474bf9 · 5474bf9
1 parent b0b88d7
commit 5474bf9
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/telemetry/proxy.py b/telemetry/proxy.py
@@ -58,9 +58,9 @@ def _cleanup(self):
 
     def flush_queue(self):
         if self.agg_queue_size > 0:
-            if self.agg_queue_timer is not None:
-                if not self.agg_queue_timer.called:
-                    self.agg_queue_timer.cancel()
+            if self.agg_queue_timer is not None \
+               and not self.agg_queue_timer.called:
+                self.agg_queue_timer.cancel()
             self.agg_queue_timer = None
             self._send_to_peer(b''.join(self.agg_queue))
             self.agg_queue = []