summaryrefslogtreecommitdiff
path: root/modules/nifi/core.py
diff options
context:
space:
mode:
authorRasmus Luha <rasmus.luha@ut.ee>2025-05-14 22:31:44 +0300
committerRasmus Luha <rasmus.luha@ut.ee>2025-05-14 22:31:44 +0300
commit7bfcf9a86553f7158673758cd500eece8e9cf132 (patch)
tree91fa5eb7d894699121c73c6b0691f894d3e1b51e /modules/nifi/core.py
parent6cb9f3eb1614f097992e27f2309bf6ca1cd37238 (diff)
Add wrong API error detection to noninteractive mode
Diffstat (limited to 'modules/nifi/core.py')
-rw-r--r--modules/nifi/core.py12
1 files changed, 12 insertions, 0 deletions
diff --git a/modules/nifi/core.py b/modules/nifi/core.py
index 0d6ca17..2e8339b 100644
--- a/modules/nifi/core.py
+++ b/modules/nifi/core.py
@@ -7,6 +7,7 @@ from rich.console import Console
import shutil
import re
+import sys
def introduction():
@@ -122,6 +123,17 @@ def build_pipeline():
api_username = config.API_USERNAME
api_password = config.API_PASSWORD
+
+ ## Check that API URL is correct
+ needs_auth = False
+ if (api_username.lower() and api_username.lower() != "placeholder") and (api_password.lower() and api_password.lower() != "placeholder"):
+ needs_auth = True
+
+ _, api_url_correct = common.is_app_url_correct(api_url, needs_auth, api_username, api_password)
+ if not api_url_correct:
+ print("\nEtteantud API URL-i kutsel tekkis viga, sulgen rakenduse...")
+ sys.exit(1)
+
modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_url, api_username, api_password)
print(f"✅✅✅ Valmis. Uus genereeritud andmekoveier nimega '{new_pipeline_name}' asub kaustas 'pipelines'.")