summaryrefslogtreecommitdiff
path: root/modules/nifi
diff options
context:
space:
mode:
authorRasmus Luha <rasmus.luha@ut.ee>2025-05-12 13:13:22 +0300
committerRasmus Luha <rasmus.luha@ut.ee>2025-05-12 13:13:22 +0300
commit6cb9f3eb1614f097992e27f2309bf6ca1cd37238 (patch)
treef4f2ca7739d98e10ed8dda201f2e088558ed9796 /modules/nifi
parentaad1cf42f85eb1a2e2a34bf997a03f2941ec99de (diff)
update README.md, cleanup
Diffstat (limited to 'modules/nifi')
-rw-r--r--modules/nifi/core.py2
1 files changed, 0 insertions, 2 deletions
diff --git a/modules/nifi/core.py b/modules/nifi/core.py
index 5c15837..0d6ca17 100644
--- a/modules/nifi/core.py
+++ b/modules/nifi/core.py
@@ -1,4 +1,3 @@
-## TODO - check syntax
from common import core as common
import config
from modules.nifi import nifi_utils
@@ -67,7 +66,6 @@ def modify_all_processors(data_values, schedulingPeriod, new_pipeline_name, api_
nifi_utils.update_template(new_pipeline_path, "flowContents.processors[3].properties", "JsonPath Expression", split_json_path)
## EvaluateJsonPath processor setup
- ## TODO
for key, value in data_values.items() :
path_parts = value.split(']')
nifi_utils.update_template(new_pipeline_path, "flowContents.processors[2].properties", key, "$"+path_parts[1])