pep8

yandex · Jun 5, 2018 · 4a3a604 · 4a3a604
1 parent a5a3bbf
commit 4a3a604
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/yandextank/plugins/YASM/plugin.py b/yandextank/plugins/YASM/plugin.py
@@ -134,8 +134,7 @@ def __init__(self, yasm_cfg, yasmapi_timeout):
         self.ps_pool = {panel.alias: Process(target=self.single_receiver,
                                              args=(panel,))
                         for panel in self.panels}
-        self.consumers = {panel.alias: Thread(target=self.single_controller,
-                                 args=(panel, self.ps_pool[panel.alias]))
+        self.consumers = {panel.alias: Thread(target=self.single_controller, args=(panel, self.ps_pool[panel.alias]))
                           for panel in self.panels}
 
     def get_buffered_data(self):
@@ -205,7 +204,8 @@ def stop_now(self):
                         self.ps_pool[panel.alias].join()
                         self.consumers[panel.alias].join()
                 active_panels = [panel for panel in active_panels if not panel.stop_trigger.is_set()]
-                if len(active_panels) > 0: time.sleep(5)
+                if len(active_panels) > 0:
+                    time.sleep(5)
             except KeyboardInterrupt:
                 logger.info('Metrics receiving interrupted')
                 [panel.stop_trigger.set() for panel in active_panels]