@@ -9,14 +9,6 @@ def __init__(self, client):
9
9
self .client = client
10
10
self .logger = logging .getLogger (__name__ )
11
11
12
- def health_check_plugin (self , pluginId ):
13
- """
14
- :return:
15
- """
16
- path = "/plugins/%s/health" % pluginId
17
- r = self .client .GET (path )
18
- return r
19
-
20
12
def get_installed_plugins (self ):
21
13
"""
22
14
:return:
@@ -25,7 +17,7 @@ def get_installed_plugins(self):
25
17
r = self .client .GET (path )
26
18
return r
27
19
28
- def install_plugin (self , pluginId , version ):
20
+ def install_plugin (self , pluginId , version , errors = "raise" ):
29
21
"""
30
22
: return:
31
23
"""
@@ -34,10 +26,15 @@ def install_plugin(self, pluginId, version):
34
26
r = self .client .POST (path , json = {"version" : version })
35
27
return r
36
28
except Exception as ex :
37
- self .logger .info ("Skipped installing %s and err = %s" , pluginId , ex )
29
+ if errors == "raise" :
30
+ raise
31
+ elif errors == "ignore" :
32
+ self .logger .info (f"Skipped installing plugin { pluginId } : { ex } " )
33
+ else :
34
+ raise ValueError (f"error={ errors } is invalid" )
38
35
return None
39
36
40
- def uninstall_plugin (self , pluginId ):
37
+ def uninstall_plugin (self , pluginId , errors = "raise" ):
41
38
"""
42
39
: return:
43
40
"""
@@ -46,17 +43,26 @@ def uninstall_plugin(self, pluginId):
46
43
r = self .client .POST (path )
47
44
return r
48
45
except Exception as ex :
49
- self .logger .info ("Skipped uninstalling %s and error = %s" , pluginId , ex )
46
+ if errors == "raise" :
47
+ raise
48
+ elif errors == "ignore" :
49
+ self .logger .info (f"Skipped uninstalling plugin { pluginId } : { ex } " )
50
+ else :
51
+ raise ValueError (f"error={ errors } is invalid" )
50
52
return None
51
53
54
+ def health_check_plugin (self , pluginId ):
55
+ """
56
+ :return:
57
+ """
58
+ path = "/plugins/%s/health" % pluginId
59
+ r = self .client .GET (path )
60
+ return r
61
+
52
62
def get_plugin_metrics (self , pluginId ):
53
63
"""
54
64
: return:
55
65
"""
56
- try :
57
- path = "/plugins/%s/metrics" % pluginId
58
- r = self .client .GET (path )
59
- return r
60
- except Exception as ex :
61
- self .logger .info ("Got error in fetching metrics for plugin %s and error = %s" , pluginId , ex )
62
- return None
66
+ path = "/plugins/%s/metrics" % pluginId
67
+ r = self .client .GET (path )
68
+ return r
0 commit comments