diff options
| author | Rasmus Luha <rasmus.luha@ut.ee> | 2025-05-05 00:55:07 +0300 |
|---|---|---|
| committer | Rasmus Luha <rasmus.luha@ut.ee> | 2025-05-05 00:55:07 +0300 |
| commit | ab4d535e4caf1d5fc1ed8097407b13bf8a0d98af (patch) | |
| tree | d3b325d37823d4ea1ede768bcbb7eeb4adcf7189 /modules/nifi/core.py | |
| parent | 737f498e1f402a5a41068a37ab20f34cabd4b052 (diff) | |
fix nifi pipeline deployment
Diffstat (limited to 'modules/nifi/core.py')
| -rw-r--r-- | modules/nifi/core.py | 4 |
1 files changed, 2 insertions, 2 deletions
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) |