Merge pull request #13 from VIDA-NYU/syncing-API-example

reformat JSON

bugdoc_api/bugdoc/algos/debugging_decision_trees.py

@@ -243,7 +243,7 @@ def assembletests(self, moralflag, path):
 
     def run(self, entry_point, input_dict, outputs=['results'], rebuild=True):
         super().run(entry_point, input_dict, outputs=outputs)
-        self.allexperiments, self.allresults, self.pv_goodness = load_runs(self.entry_point + ".adb",
+        self.allexperiments, self.allresults, self.pv_goodness = load_runs(self.entry_point,
                                                                            self.my_inputs)
         logging.debug("pv_goodness is: " + str(self.pv_goodness))
         logging.debug("allresults is: " + str(self.allresults))

bugdoc_api/bugdoc/algos/shortcut.py

@@ -65,7 +65,7 @@ def get_good_and_bad_instances(self, goodlist, badlist):
 
     def run(self, entry_point, input_dict, outputs=['results']):
         super().run(entry_point, input_dict, outputs=outputs)
-        self.allexperiments, self.allresults, _ = load_runs(self.entry_point + ".adb", self.my_inputs)
+        self.allexperiments, self.allresults, _ = load_runs(self.entry_point , self.my_inputs)
         # logging.debug("allresults is: "+str(self.allresults))
         requests = set()
         expers = [self.allresults[j][:-1] for j in range(len(self.allresults))]

bugdoc_api/bugdoc/algos/stacked_shortcut.py

@@ -89,7 +89,7 @@ def get_good_and_bad_instances(self, goodlist, badlist):
 
     def run(self, entry_point, input_dict, outputs=['results']):
         super().run(entry_point, input_dict, outputs=outputs)
-        self.allexperiments, self.allresults, _ = load_runs(self.entry_point + ".adb", self.my_inputs)
+        self.allexperiments, self.allresults, _ = load_runs(self.entry_point, self.my_inputs)
         logging.debug("allresults is: "+str(self.allresults))
         requests = set()
         expers = [self.allresults[j][:-1] for j in range(len(self.allresults))]

bugdoc_api/bugdoc/utils/utils.py

@@ -37,6 +37,7 @@
 
 import copy
 import json
+import logging
 import os
 import sys
 import traceback
@@ -45,6 +46,8 @@
 from builtins import range
 from bugdoc.utils.combinatorial_design import generate_tuples
 
+logging.basicConfig(format='%(levelname)s:%(message)s', level=logging.DEBUG)
+
 goodbad = [True, False]
 numtests = 30
 
@@ -77,7 +80,7 @@ def load_runs(filename, input_keys, lims=None):
         try:
             exp = []
             exp_dict = json.loads(e[:-1])
-
+            
             result_value = exp_dict['result']
 
             for key in input_keys:
@@ -199,6 +202,10 @@ def record_pipeline_run(filename,values,parameters,result, origin=None):
 
     if origin:
         paramDict["origin"] = origin
+
+    logging.debug('Filename: ' + filename)
+    logging.debug('New configuration: ' + str(paramDict))
+
     f = open(filename, "a")
     f.write(json.dumps(paramDict) + '\n')
     f.close()

bugdoc_cli/bugdoc_cli_worker.py

@@ -69,6 +69,6 @@ def main():
             result = False
             logging.error("-" * 60)
 
-        record_pipeline_run(entry_point + ".adb", values, parameters, result)
+        record_pipeline_run(entry_point, values, parameters, result)
         values.append(result)
         sender.send_string(str(values))

examples/conf_my_api_example.json

@@ -1,5 +1,5 @@
 {
-  "entry_point": "my_pipeline",
+  "entry_point": "dataflow_pipeline.json",
   "python_module": "my_api_example",
   "run": "execute_pipeline",
   "parameters": [

examples/debugger.py

@@ -12,7 +12,7 @@
 # --------------------------------------
 # We choose the Stacked Shortcut Algorithm to debug the pipeline.
 
-from bugdoc.algos.stacked_shortcut import AutoDebug as StackedShortcut
+from bugdoc.algos.stacked_shortcut import StackedShortcut
 
 # %%
 # Parameter space definition
@@ -72,7 +72,7 @@
 
 root, _, _ = result
 parameters = list(parameter_space.keys())
-print('Root Cause: \\n%s' % (
+print('Root Cause: \n%s' % (
     ' OR '.join(
      [
         ' AND '.join(