diff --git a/telemetry/proxy.py b/telemetry/proxy.py
index b52128c..c7244e4 100644
--- a/telemetry/proxy.py
+++ b/telemetry/proxy.py
@@ -58,9 +58,9 @@ class UDPProxyProtocol(DatagramProtocol):
 
     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 = []