From e5d51b57a83f17a471b69d83c39655c1523b66d6 Mon Sep 17 00:00:00 2001 From: shabs2020 Date: Fri, 4 Jun 2021 12:08:23 +0200 Subject: Adapt DCAE adapter to work with Acumos Demeter's metadata structure change Fix the dataformat generation failure due to Demeter's metadata change. At the same maintain its backward compatibility with Acumos Clio. Issue-ID: DCAEGEN2-2825 Signed-off-by: shabs2020 Change-Id: I0f665415d1b3c94e774eec5a56c8df598d222cd3 Signed-off-by: shabs2020 --- adapter/acumos/aoconversion/spec_gen.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'adapter/acumos/aoconversion/spec_gen.py') diff --git a/adapter/acumos/aoconversion/spec_gen.py b/adapter/acumos/aoconversion/spec_gen.py index 8564434..a08b720 100644 --- a/adapter/acumos/aoconversion/spec_gen.py +++ b/adapter/acumos/aoconversion/spec_gen.py @@ -2,6 +2,7 @@ # org.onap.dcae # ============================================================================= # Copyright (c) 2019-2020 AT&T Intellectual Property. All rights reserved. +# Copyright (c) 2021 highstreet technologies GmbH. 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. @@ -62,7 +63,7 @@ def _generate_spec(model_name, meta, dcae_cs_schema, data_formats, docker_uri): pstype = "message_router" for method in meta["methods"]: - df_in_name = meta["methods"][method]["input"] + df_in_name = utils.validate_format(meta, method, "input") subscriber = { "config_key": "{0}_subscriber".format(method), "format": df_in_name, @@ -72,7 +73,7 @@ def _generate_spec(model_name, meta, dcae_cs_schema, data_formats, docker_uri): spec["streams"]["subscribes"].append(subscriber) - df_out_name = meta["methods"][method]["output"] + df_out_name = utils.validate_format(meta, method, "output") publisher = { "config_key": "{0}_publisher".format(method), -- cgit 1.2.3-korg