Update NiFi and NiFi-Registry clients to the 1.17.0 release

Update docker resources to the latest 1.17 container image
Fix issue in docker volume mounts where certificates were not readable in new versions of Docker
Fix issue in test_get_processor_type where new Twitter processor broke existing logic assumptions
Update readme to note issues with Python 3.10 and removing reference to python 3.5 testing

Signed-off-by: Daniel Chaffelson <[email protected]>

Author: Chaffelson

README.rst

@@ -99,6 +99,6 @@ NiFi Version Support
 Python Requirements
 -------------------
 
-| Python 2.7 or 3.5-8 supported, though other versions may work. *We will shortly stop supporting Python2*
+| Python 2.7 or 3.6-9 supported, though other versions may work. *We will shortly stop supporting Python2* *There are known issues on Python 3.10*
 | Tested on AL2 and OSX 10.14.x - Windows automated testing not attempted
 | Outside of the standard Python modules, we make use of lxml, DeepDiff, ruamel.yaml and xmltodict in processing, and Docker for demo/tests.

nipyapi/nifi/__init__.py

@@ -5,7 +5,7 @@
 
     The Rest API provides programmatic access to command and control a NiFi instance in real time. Start and                                             stop processors, monitor queues, query provenance data, and more. Each endpoint below includes a description,                                             definitions of the expected input and output, potential response codes, and the authorizations required                                             to invoke each service.
 
-    OpenAPI spec version: 1.16.1
+    OpenAPI spec version: 1.17.0
     Contact: [email protected]
     Generated by: https://github.com/swagger-api/swagger-codegen.git
 """
@@ -24,6 +24,8 @@
 from .models.access_policy_summary_entity import AccessPolicySummaryEntity
 from .models.access_status_dto import AccessStatusDTO
 from .models.access_status_entity import AccessStatusEntity
+from .models.access_token_expiration_dto import AccessTokenExpirationDTO
+from .models.access_token_expiration_entity import AccessTokenExpirationEntity
 from .models.action_dto import ActionDTO
 from .models.action_details_dto import ActionDetailsDTO
 from .models.action_entity import ActionEntity
@@ -281,6 +283,7 @@
 from .models.required_permission_dto import RequiredPermissionDTO
 from .models.resource_dto import ResourceDTO
 from .models.resources_entity import ResourcesEntity
+from .models.restriction import Restriction
 from .models.revision_dto import RevisionDTO
 from .models.revision_info import RevisionInfo
 from .models.run_status_details_request_entity import RunStatusDetailsRequestEntity
@@ -364,7 +367,6 @@
 # import apis into sdk package
 from .apis.access_api import AccessApi
 from .apis.accessoidc_api import AccessoidcApi
-from .apis.accesssaml_api import AccesssamlApi
 from .apis.connections_api import ConnectionsApi
 from .apis.controller_api import ControllerApi
 from .apis.controller_services_api import ControllerServicesApi

nipyapi/nifi/api_client.py

@@ -4,7 +4,7 @@
 
     The Rest API provides programmatic access to command and control a NiFi instance in real time. Start and                                             stop processors, monitor queues, query provenance data, and more. Each endpoint below includes a description,                                             definitions of the expected input and output, potential response codes, and the authorizations required                                             to invoke each service.
 
-    OpenAPI spec version: 1.16.1
+    OpenAPI spec version: 1.17.0
     Contact: [email protected]
     Generated by: https://github.com/swagger-api/swagger-codegen.git
 """

nipyapi/nifi/apis/__init__.py

@@ -3,7 +3,6 @@
 # import apis into api package
 from .access_api import AccessApi
 from .accessoidc_api import AccessoidcApi
-from .accesssaml_api import AccesssamlApi
 from .connections_api import ConnectionsApi
 from .controller_api import ControllerApi
 from .controller_services_api import ControllerServicesApi

nipyapi/nifi/apis/access_api.py

@@ -5,7 +5,7 @@
 
     The Rest API provides programmatic access to command and control a NiFi instance in real time. Start and                                             stop processors, monitor queues, query provenance data, and more. Each endpoint below includes a description,                                             definitions of the expected input and output, potential response codes, and the authorizations required                                             to invoke each service.
 
-    OpenAPI spec version: 1.16.1
+    OpenAPI spec version: 1.17.0
     Contact: [email protected]
     Generated by: https://github.com/swagger-api/swagger-codegen.git
 """
@@ -343,6 +343,100 @@ def get_access_status_with_http_info(self, **kwargs):
                                         _request_timeout=params.get('_request_timeout'),
                                         collection_formats=collection_formats)
 
+    def get_access_token_expiration(self, **kwargs):
+        """
+        Get expiration for current Access Token
+        Note: This endpoint is subject to change as NiFi and it's REST API evolve.
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please define a `callback` function
+        to be invoked when receiving the response.
+        >>> def callback_function(response):
+        >>>     pprint(response)
+        >>>
+        >>> thread = api.get_access_token_expiration(callback=callback_function)
+
+        :param callback function: The callback function
+            for asynchronous request. (optional)
+        :return: AccessTokenExpirationEntity
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+        kwargs['_return_http_data_only'] = True
+        if kwargs.get('callback'):
+            return self.get_access_token_expiration_with_http_info(**kwargs)
+        else:
+            (data) = self.get_access_token_expiration_with_http_info(**kwargs)
+            return data
+
+    def get_access_token_expiration_with_http_info(self, **kwargs):
+        """
+        Get expiration for current Access Token
+        Note: This endpoint is subject to change as NiFi and it's REST API evolve.
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please define a `callback` function
+        to be invoked when receiving the response.
+        >>> def callback_function(response):
+        >>>     pprint(response)
+        >>>
+        >>> thread = api.get_access_token_expiration_with_http_info(callback=callback_function)
+
+        :param callback function: The callback function
+            for asynchronous request. (optional)
+        :return: AccessTokenExpirationEntity
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+
+        all_params = []
+        all_params.append('callback')
+        all_params.append('_return_http_data_only')
+        all_params.append('_preload_content')
+        all_params.append('_request_timeout')
+
+        params = locals()
+        for key, val in iteritems(params['kwargs']):
+            if key not in all_params:
+                raise TypeError(
+                    "Got an unexpected keyword argument '%s'"
+                    " to method get_access_token_expiration" % key
+                )
+            params[key] = val
+        del params['kwargs']
+
+        collection_formats = {}
+
+        path_params = {}
+
+        query_params = []
+
+        header_params = {}
+
+        form_params = []
+        local_var_files = {}
+
+        body_params = None
+        # HTTP header `Accept`
+        header_params['Accept'] = self.api_client.\
+            select_header_accept(['application/json'])
+
+        # Authentication setting
+        auth_settings = ['tokenAuth']
+
+        return self.api_client.call_api('/access/token/expiration', 'GET',
+                                        path_params,
+                                        query_params,
+                                        header_params,
+                                        body=body_params,
+                                        post_params=form_params,
+                                        files=local_var_files,
+                                        response_type='AccessTokenExpirationEntity',
+                                        auth_settings=auth_settings,
+                                        callback=params.get('callback'),
+                                        _return_http_data_only=params.get('_return_http_data_only'),
+                                        _preload_content=params.get('_preload_content', True),
+                                        _request_timeout=params.get('_request_timeout'),
+                                        collection_formats=collection_formats)
+
     def get_login_config(self, **kwargs):
         """
         Retrieves the access configuration for this NiFi

nipyapi/nifi/apis/accessoidc_api.py

@@ -5,7 +5,7 @@
 
     The Rest API provides programmatic access to command and control a NiFi instance in real time. Start and                                             stop processors, monitor queues, query provenance data, and more. Each endpoint below includes a description,                                             definitions of the expected input and output, potential response codes, and the authorizations required                                             to invoke each service.
 
-    OpenAPI spec version: 1.16.1
+    OpenAPI spec version: 1.17.0
     Contact: [email protected]
     Generated by: https://github.com/swagger-api/swagger-codegen.git
 """