diff options
Diffstat (limited to 'test/mocks/pnfsimulator/netconfsimulator/netconf/yang_loader_server.py')
| -rw-r--r-- | test/mocks/pnfsimulator/netconfsimulator/netconf/yang_loader_server.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/mocks/pnfsimulator/netconfsimulator/netconf/yang_loader_server.py b/test/mocks/pnfsimulator/netconfsimulator/netconf/yang_loader_server.py index 716d0712e..f414467d0 100644 --- a/test/mocks/pnfsimulator/netconfsimulator/netconf/yang_loader_server.py +++ b/test/mocks/pnfsimulator/netconfsimulator/netconf/yang_loader_server.py @@ -31,7 +31,7 @@ app = Flask(__name__) api = Api(app) logger = logging.getLogger("yang-loader") logger.addHandler(logging.StreamHandler()) -KAFKA_BROKER_NAME="kafka1" +KAFKA_BROKER_NAME="kafka1:9092" KAFKA_TOPIC_NAME="config" @@ -68,7 +68,7 @@ class YangLoaderHelper(object): @classmethod def start_change_listener_for_model(cls, module_name: str): logger.info("Starting listener for model: %s", module_name) - command = "/opt/dev/netopeer-change-saver/bin/netopeer-change-saver {} {} {}" \ + command = "python /netconf/netopeer_change_saver.py {} {} {}" \ .format(module_name, KAFKA_BROKER_NAME, KAFKA_TOPIC_NAME) try: check_output(["pgrep", "-f" , command], stderr=subprocess.STDOUT, universal_newlines=True) |