From ab4d535e4caf1d5fc1ed8097407b13bf8a0d98af Mon Sep 17 00:00:00 2001 From: Rasmus Luha Date: Mon, 5 May 2025 00:55:07 +0300 Subject: fix nifi pipeline deployment --- modules/nifi/core.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'modules') diff --git a/modules/nifi/core.py b/modules/nifi/core.py index bcf50c0..79ab5b9 100644 --- a/modules/nifi/core.py +++ b/modules/nifi/core.py @@ -114,9 +114,9 @@ def build_pipeline(): ## Pipeline Deployment if (config.NIFI_DEPLOY): token = nifi_utils.get_access_token() - nifi_utils.upload_nifi_pipeline(token, "pipelines/test_pipeline.json", "test_pipeline", username=config.NIFI_USER, password=config.NIFI_PASS, nifi_url=config.NIFI_HOST, position_x=0, position_y=0) + nifi_utils.upload_nifi_pipeline(token, f"pipelines/{new_pipeline_name}", new_pipeline_name.split(".")[0], username=config.NIFI_USER, password=config.NIFI_PASS, nifi_url=config.NIFI_HOST, position_x=0, position_y=0) else: choice = common.ask_binary_input(prompt="\nKas soovid genereeritud andmekonveieri nifi platvormile paigaldada?(jah/ei): ",valikud=["jah","ei"]).strip().lower() if choice == "jah": token = nifi_utils.get_access_token() - nifi_utils.upload_nifi_pipeline(token, "pipelines/test_pipeline.json", "test_pipeline", username=config.NIFI_USER, password=config.NIFI_PASS, nifi_url=config.NIFI_HOST, position_x=0, position_y=0) + nifi_utils.upload_nifi_pipeline(token, f"pipelines/{new_pipeline_name}", new_pipeline_name.split(".")[0], username=config.NIFI_USER, password=config.NIFI_PASS, nifi_url=config.NIFI_HOST, position_x=0, position_y=0) -- cgit v1.2.3