Return JSON to stdout from CLI

Author: ml-evs

beam/__init__.py

@@ -214,6 +214,10 @@ def run_datatractor():
     try:
         ret = func(**vars(args))
         if ret is not None and len(ret) > 0:
+            try:
+                ret = json.dumps(ret)
+            except json.JSONDecodeError:
+                pass
             print(ret)
     except RuntimeError as e:
         print(e)
@@ -507,7 +511,7 @@ def fetch_registered_extractors(
         )
     elif len(extractors) > 0:
         logger.info("Discovered the following extractors: %s.", extractors)
-    return extractors
+    return {"id": input_type, "registered_extractors": extractors}
 
 
 class ExtractorPlan: