fix: determine nifi version in nifi 1 create reporting task script

Author: dervoeti

nifi/python/create_nifi_reporting_task.py

@@ -47,16 +47,21 @@ def find_reporting_task(name: str, port: str):
     return None
 
 
-def create_reporting_task(name: str, port: str, version: str):
+def create_reporting_task(name: str, port: str):
     """Create a ReportingTask"""
+    nifi_version = (
+        nipyapi.system.get_system_diagnostics().system_diagnostics.aggregate_snapshot.version_info.ni_fi_version
+    )
     task = nipyapi.nifi.models.reporting_task_entity.ReportingTaskEntity(
         revision=nipyapi.nifi.models.revision_dto.RevisionDTO(version=0),
         disconnected_node_acknowledged=False,
         component=nipyapi.nifi.models.reporting_task_dto.ReportingTaskDTO(
             name=name,
             type="org.apache.nifi.reporting.prometheus.PrometheusReportingTask",
             bundle=nipyapi.nifi.models.bundle_dto.BundleDTO(
-                group="org.apache.nifi", artifact="nifi-prometheus-nar", version=version
+                group="org.apache.nifi",
+                artifact="nifi-prometheus-nar",
+                version=nifi_version,
             ),
             properties={
                 "prometheus-reporting-task-metrics-endpoint-port": port,
@@ -159,7 +164,7 @@ def main():
 
     if reporting_task is None:
         reporting_task = create_reporting_task(
-            name=task_name, port=port, version=args["nifi_version"]
+            name=task_name, port=port
         )
         print(
             get_reporting_task_name(task=reporting_task)