From 5509ef5b96a5b5fd5b4aeead8761e12f62575a30 Mon Sep 17 00:00:00 2001
From: Stephen Mardson McQuay <stephen@mcquay.me>
Date: Wed, 18 May 2011 12:57:09 -0600
Subject: [PATCH 1/2] added simplified improvement test

---
 interp/tools.py | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/interp/tools.py b/interp/tools.py
index a86f9ba..74c35d8 100644
--- a/interp/tools.py
+++ b/interp/tools.py
@@ -65,7 +65,11 @@ def improved_answer(answer, exact):
   else:
     log.debug(":( damaged result")
     return False
-
+def improved(qlin, err, final, exact):
+  if np.abs(final - exact) <= np.abs(qlin - exact):
+    return True
+  else:
+    return False
 
 def percent_improvement(answer, exact):
   return np.abs(answer['error']) / exact

From 2a4a5b7ebe3ca609e9a61c2ae0feb101e39e36fc Mon Sep 17 00:00:00 2001
From: Stephen Mardson McQuay <stephen@mcquay.me>
Date: Wed, 18 May 2011 12:57:28 -0600
Subject: [PATCH 2/2] improved the shepherd and enabled actual task submission

---
 bin/shepherd.py | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/bin/shepherd.py b/bin/shepherd.py
index c9c5889..d74b4f3 100644
--- a/bin/shepherd.py
+++ b/bin/shepherd.py
@@ -21,7 +21,7 @@ log = logging.getLogger("interp")
 from interp.cluster import QueueManager, get_qs
 
 if __name__ == '__main__':
-  parser = OptionParser(usage = "%prog [options] <server> <destination vertexes file (pickle)>")
+  parser = OptionParser(usage = "%prog [options] <server> <destination vertexes file (pickle)> <results pickle>")
 
   parser.add_option("-v", "--verbose",
     action="store_true", dest="verbose", default=False,
@@ -36,11 +36,11 @@ if __name__ == '__main__':
     help="specify how many participants we should wait for (default: %default)")
 
   (options, args) = parser.parse_args()
-  if len(args) != 2:
+  if len(args) != 3:
     parser.print_usage()
     sys.exit(1)
 
-  server, dest_verts = args
+  server, dest_verts, results_p_name = args
 
   dest_verts = pickle.load(open(dest_verts, 'r'))
 
@@ -89,7 +89,7 @@ if __name__ == '__main__':
         for X in d:
           cur_job    = (i, order, extra, X)
           results[i] = [   order, extra, X]
-          # tasksq.put(cur_job)
+          tasksq.put(cur_job)
           i+=1
           pbar.update(i)
   submit_end = time.time()
@@ -114,7 +114,7 @@ if __name__ == '__main__':
   receive_end = time.time()
   pbar.finish()
 
-  pickle.dump(results, open("results.p"))
+  pickle.dump(results, open(results_p_name, 'w'))
 
   submit  = submit_end - submit_start
   receive = receive_end - receive_start