Switching to beta version of k8s client for resource version fix

Author: max-rocket-internet

controller.py

@@ -51,6 +51,9 @@
             if e.status == 404:
                 logger.error('Custom Resource Definition not created in cluster')
                 sys.exit(1)
+            elif e.status == 401:
+                logger.error('Unauthorized')
+                sys.exit(1)
             else:
                 raise e
         except KeyboardInterrupt:

functions.py

@@ -154,7 +154,7 @@ def process_event(crds, obj, event_type):
                     logger.info('Failed to list alerts policies: {0}'.format(parse_api_error(e)))
                     return
                 else:
-                    logger.info('Found existing alerts policy with ID: {0}'.format(policy_id))
+                    logger.info('Found existing alerts policy with ID {0}'.format(policy_id))
 
                 if policy_id == None:
                     try:

requirements.txt

@@ -1,2 +1,2 @@
 urllib3==1.23
-kubernetes==8.0.0a1
+kubernetes==9.0.0b1