Fix threads parsing bugs (#909)

Signed-off-by: Ching Yi, Chan <[email protected]>
Co-authored-by: wcchang <[email protected]>

piperider_cli/__init__.py

@@ -205,9 +205,23 @@ def as_bool(var):
     def as_number(var):
         if var is None:
             return var
-        if var.isnumeric():
-            return int(var)
-        return float(var)
+
+        # the input has been a numeric value
+        if isinstance(var, int) or isinstance(var, float):
+            return var
+
+        # the input is str, but could convert to a numeric value
+        try:
+            if isinstance(var, str):
+                if var.isnumeric():
+                    return int(var)
+                else:
+                    return float(var)
+        except BaseException:
+            # fail to covert
+            raise
+        # unknown cases
+        return var
 
     def as_text(var):
         if var is None:

piperider_cli/datasource/__init__.py

@@ -110,7 +110,13 @@ def threads(self):
         except Exception:
             engine = None
         if self.credential.get('threads'):
-            return self.credential.get('threads')
+            try:
+                return int(self.credential.get('threads'))
+            except BaseException:
+                console = Console()
+                message = 'failed to parse the "threads" field, so we will use 1 thread to execute profiling.'
+                console.print(f'[bold yellow]Warning: [/bold yellow]:\n  {message}')
+                return 1
         elif engine and not isinstance(engine.pool, SingletonThreadPool):
             return 5
         else: