X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=testsuites%2Fvstf%2Fvstf_scripts%2Fvstf%2Fcontroller%2Fsw_perf%2Fflow_producer.py;h=a4bd1467700f5f2a0d4550cbdbd0e50ecd090313;hb=6204bfbe6228d5167bdb67c42cac4c884cdcf664;hp=4a3b02c218bff60ebda016e31c7677853d80e22c;hpb=3ac496ac711f40f2a4c4fb0837758b4fbade43e4;p=bottlenecks.git

diff --git a/testsuites/vstf/vstf_scripts/vstf/controller/sw_perf/flow_producer.py b/testsuites/vstf/vstf_scripts/vstf/controller/sw_perf/flow_producer.py
index 4a3b02c2..a4bd1467 100644
--- a/testsuites/vstf/vstf_scripts/vstf/controller/sw_perf/flow_producer.py
+++ b/testsuites/vstf/vstf_scripts/vstf/controller/sw_perf/flow_producer.py
@@ -21,6 +21,7 @@ LOG = logging.getLogger(__name__)
 
 
 class FlowsProducer(object):
+
     def __init__(self, conn, flows_settings):
         self._perf = flows_settings
         self._forwarding = ForwardingSettings().settings
@@ -43,12 +44,13 @@ class FlowsProducer(object):
             raise Exception("error devs :%s", devs)
         LOG.info(agent)
         LOG.info(name)
-        if not self._devs_map.has_key((agent, name)):
+        if (agent, name) not in self._devs_map:
             query = Fabricant(agent, self._conn)
             query.clean_all_namespace()
             dev_info = query.get_device_verbose(identity=name)
             if not isinstance(dev_info, dict):
-                err = "get device detail failed, agent:%s net:%s" % (agent, name)
+                err = "get device detail failed, agent:%s net:%s" % (
+                    agent, name)
                 raise Exception(err)
             dev = {
                 "agent": agent,
@@ -127,7 +129,10 @@ class FlowsProducer(object):
 def unit_test():
     from vstf.rpc_frame_work.rpc_producer import Server
     from vstf.common.log import setup_logging
-    setup_logging(level=logging.INFO, log_file="/var/log/vstf/vstf-producer.log", clevel=logging.INFO)
+    setup_logging(
+        level=logging.INFO,
+        log_file="/var/log/vstf/vstf-producer.log",
+        clevel=logging.INFO)
 
     conn = Server("192.168.188.10")
     flow_settings = FlowsSettings()