X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_lcm%2Ftests%2Ftest_ns.py;h=20047016645ceef321716447d82db0e6f851a823;hb=28b0bf87c3fe2bd99cd3d5665eae484df8c3b44c;hp=560edc971a47a510cc7249e1610c28836e1b6b5a;hpb=506398326f3d6c95e423ff3b9185a3ffe6a8abe0;p=osm%2FLCM.git

diff --git a/osm_lcm/tests/test_ns.py b/osm_lcm/tests/test_ns.py
index 560edc9..2004701 100644
--- a/osm_lcm/tests/test_ns.py
+++ b/osm_lcm/tests/test_ns.py
@@ -122,15 +122,11 @@ class TestMyNS(asynctest.TestCase):
         print("kwargs > {}".format(kwargs))
         if args:
             if "update" in args:
-                ro_ns_desc = yaml.safe_load(
-                    descriptors.ro_update_action_text
-                )
+                ro_ns_desc = yaml.safe_load(descriptors.ro_update_action_text)
                 while True:
                     yield ro_ns_desc
         if kwargs.get("delete"):
-            ro_ns_desc = yaml.safe_load(
-                descriptors.ro_delete_action_text
-            )
+            ro_ns_desc = yaml.safe_load(descriptors.ro_delete_action_text)
             while True:
                 yield ro_ns_desc
 
@@ -176,19 +172,13 @@ class TestMyNS(asynctest.TestCase):
             Database.instance = None
 
             self.db = Database({"database": {"driver": "memory"}}).instance.db
-            self.db.create_list(
-                "vnfds", yaml.safe_load(descriptors.db_vnfds_text)
-            )
+            self.db.create_list("vnfds", yaml.safe_load(descriptors.db_vnfds_text))
             self.db.create_list(
                 "vnfds_revisions",
                 yaml.safe_load(descriptors.db_vnfds_revisions_text),
             )
-            self.db.create_list(
-                "nsds", yaml.safe_load(descriptors.db_nsds_text)
-            )
-            self.db.create_list(
-                "nsrs", yaml.safe_load(descriptors.db_nsrs_text)
-            )
+            self.db.create_list("nsds", yaml.safe_load(descriptors.db_nsds_text))
+            self.db.create_list("nsrs", yaml.safe_load(descriptors.db_nsrs_text))
             self.db.create_list(
                 "vim_accounts",
                 yaml.safe_load(descriptors.db_vim_accounts_text),
@@ -200,12 +190,8 @@ class TestMyNS(asynctest.TestCase):
             self.db.create_list(
                 "nslcmops", yaml.safe_load(descriptors.db_nslcmops_text)
             )
-            self.db.create_list(
-                "vnfrs", yaml.safe_load(descriptors.db_vnfrs_text)
-            )
-            self.db_vim_accounts = yaml.safe_load(
-                descriptors.db_vim_accounts_text
-            )
+            self.db.create_list("vnfrs", yaml.safe_load(descriptors.db_vnfrs_text))
+            self.db_vim_accounts = yaml.safe_load(descriptors.db_vim_accounts_text)
 
         # Mock kafka
         self.msg = asynctest.Mock(MsgKafka())
@@ -839,7 +825,10 @@ class TestMyNS(asynctest.TestCase):
             self.assertEqual(return_value, expected_value)
             with self.assertRaises(Exception) as context:
                 self.db.get_one("vnfrs", {"_id": vnf_instance_id})
-            self.assertTrue("database exception Not found entry with filter" in str(context.exception))
+            self.assertTrue(
+                "database exception Not found entry with filter"
+                in str(context.exception)
+            )
 
     # test vertical scale executes sucessfully
     # @patch("osm_lcm.ng_ro.status.response")