added try/except

Author: vince-weka

collector.py

@@ -380,8 +380,11 @@ def gather(self):
 
         # get info from weka cluster - these are quick calls
         for stat, command in self.WEKAINFO.items():
-            wekadata[stat] = cluster.call_api(command['method'], command['parms'])
-            self.api_stats['num_calls'] += 1
+            try:
+                wekadata[stat] = cluster.call_api(command['method'], command['parms'])
+                self.api_stats['num_calls'] += 1
+            except Exception as exc:
+                log.error(f"Error calling method {command['method']}: {exc}")
 
         # clear old maps, if any - if nodes come/go this can get funky with old data, so re-create it every time
         node_host_map = dict()

docker_build

@@ -1,5 +1,5 @@
 #!/usr/bin/env bash
 ./build.sh
 VERSION=$(./tarball/export/export --version | awk '{print $3}')
-docker build --tag wekasolutions/export:latest --tag wekasolutions/export:$VERSION .
+docker build --tag wekasolutions/export:$VERSION .
 #docker build --tag wekasolutions/export:$VERSION .

export.py

@@ -29,7 +29,7 @@
 from wekalib.wekacluster import WekaCluster
 import wekalib.exceptions
 
-VERSION = "1.6.10"
+VERSION = "1.6.11"
 
 #VERSION = "experimental"
 

requirements.txt

@@ -5,4 +5,4 @@ PyYAML>=5.4.1
 requests>=2.25.1
 six>=1.15.0
 urllib3
-wekalib>=1.4.12
+wekalib==1.4.12