Updated task_grouping.py

Author: AbelCheng

Sample/UserApps/ServicesGrouping/rest_grouping.py

@@ -5,7 +5,7 @@
 
     *   ``RestTaskLoader`` class, which is used to load a group of RESTful services (call tasks) from a JSON payload into ``TaskContainer``.
 
-    *   ``call_rest_group`` function, which is the main entry for the client to call a group of RESTful services.
+    *   ``start`` function, which is the main entry for the client to call a group of RESTful services.
 
     This module was originally shipped as an example code from https://github.com/DataBooster/PyWebApi, licensed under the MIT license.
     Anyone who obtains a copy of this code is welcome to modify it for any purpose, and holds all rights to the modified part only.
@@ -81,9 +81,9 @@ def extract_parallel_group(self, task_node:Dict[str, Any]) -> List[Dict[str, Any
 
 
 
-def call_rest_group(payload:Dict[str, Any]):
+def start(rest:Dict[str, Any]):
     """the main entry for the client to call a group of RESTful services."""
     with ThreadPoolExecutor(max_workers=32) as thread_pool:
         loader = RestTaskLoader(thread_pool)
-        container = loader.load(payload)
+        container = loader.load(rest)
         return container.run()

Utilities.PyPI/task_grouping.py

@@ -21,6 +21,7 @@
 | License: MIT
 """
 
+from collections import Iterable
 from abc import ABCMeta, abstractmethod
 from typing import Union, List, Dict, Tuple, Callable, Any
 from concurrent.futures import ThreadPoolExecutor, as_completed
@@ -91,7 +92,10 @@ def _pipe_in(self, pipeargs:Union[Dict, List[Dict]]={}) -> Dict:
             if isinstance(pipeargs, dict):
                 return pipeargs
 
-            if isinstance(pipeargs, iterable):
+            if isinstance(pipeargs, str):
+                return {}
+
+            if isinstance(pipeargs, Iterable):
                 pipe_args = {}
 
                 for p in pipeargs:
@@ -286,4 +290,4 @@ def load(self, task_tree:Dict[str, Any]) -> TaskContainer:
 
 
 
-__version__ = "0.1a0.dev1"
+__version__ = "0.1a1"