diff options
| author |   Hansen, Tony (th1395) <th1395@att.com> | 2022-08-05 22:16:14 +0000 |
|---|---|---|
| committer | Hansen, Tony (th1395) <th1395@att.com> | 2022-08-17 22:10:23 +0000 |
| commit | c83d2369eb2f0ac40d5acd2db2d7350fe86101e5 (patch) | |
| tree | d4549e4aca7248f63a0417d6718a1cfb8445a1ea /mod/distributorapi/tests/test_transform.py | |
| parent | 2b31b78fb0c6621259898c3553187be4ab0acf8a (diff) | |
codecoverage improvement
Change-Id: I69cdb741c1e07a096ddd7c85921326070fb08a92
Signed-off-by: Hansen, Tony (th1395) <th1395@att.com>
Issue-ID: DCAEGEN2-3170
Signed-off-by: Hansen, Tony (th1395) <th1395@att.com>
Diffstat (limited to 'mod/distributorapi/tests/test_transform.py')
| -rw-r--r-- | mod/distributorapi/tests/test_transform.py | 25 |
1 files changed, 13 insertions, 12 deletions
diff --git a/mod/distributorapi/tests/test_transform.py b/mod/distributorapi/tests/test_transform.py index f275e63..5ee03ac 100644 --- a/mod/distributorapi/tests/test_transform.py +++ b/mod/distributorapi/tests/test_transform.py @@ -1,5 +1,5 @@ # ============LICENSE_START======================================================= -# Copyright (c) 2019 AT&T Intellectual Property. All rights reserved. +# Copyright (c) 2019-2022 AT&T Intellectual Property. All rights reserved. # ================================================================================ # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -18,11 +18,13 @@ from distributor import transform as tr TEST_DIR = os.path.dirname(__file__) + def _load_data(filename): path = os.path.join(TEST_DIR, filename) with open(path) as f: return json.load(f) + def _setup(): flow = _load_data("flow.json") components = _load_data("components.json") @@ -50,19 +52,18 @@ def test_make_fbp_from_flow(): assert list(sorted(expected)) == list(sorted(actual)) # Test processor to processor scenario - expected = {'metadata': {'data_type': 'json', - 'dmaap_type': 'MR', - 'name': 'foo-conn'}, - 'src': {'node': '75c9a179-b36b-4985-9445-d44c8768d6eb', - 'port': 'ves-pnfRegistration-secondary'}, - 'tgt': {'node': '3fadb641-2079-4ca9-bb07-0df5952967fc', - 'port': 'predict_subscriber'}} + expected = { + "metadata": {"data_type": "json", "dmaap_type": "MR", "name": "foo-conn"}, + "src": {"node": "75c9a179-b36b-4985-9445-d44c8768d6eb", "port": "ves-pnfRegistration-secondary"}, + "tgt": {"node": "3fadb641-2079-4ca9-bb07-0df5952967fc", "port": "predict_subscriber"}, + } actual = [e["payload"] for e in fbp if e["command"] == "addedge"] assert actual[0] == expected or actual[1] == expected # Test input port to processor scenario - expected = {'metadata': {'data_type': 'json', 'dmaap_type': 'MR', - 'name': 'ves-data-conn'}, 'src': {}, - 'tgt': {'node': '75c9a179-b36b-4985-9445-d44c8768d6eb', - 'port': 'ves-notification'}} + expected = { + "metadata": {"data_type": "json", "dmaap_type": "MR", "name": "ves-data-conn"}, + "src": {}, + "tgt": {"node": "75c9a179-b36b-4985-9445-d44c8768d6eb", "port": "ves-notification"}, + } assert actual[0] == expected or actual[1] == expected |