[yt-svn] commit/yt: brittonsmith: The dynamic task queue was not actually getting called with dynamic=True.

[Bitbucket]

1 new commit in yt:


https://bitbucket.org/yt_analysis/yt/changeset/e25bbbcec539/
changeset:   e25bbbcec539
branch:      yt
user:        brittonsmith
date:        2012-06-23 16:48:41
summary:     The dynamic task queue was not actually getting called with dynamic=True.
Oops.  Fixed that.
affected #:  2 files

diff -r c5d54e6e4232b812e4754e926318aa0c5f60d587 -r e25bbbcec539a5cb2bd4810da8bbc268f208043b yt/utilities/parallel_tools/parallel_analysis_interface.py
--- a/yt/utilities/parallel_tools/parallel_analysis_interface.py
+++ b/yt/utilities/parallel_tools/parallel_analysis_interface.py
@@ -344,8 +344,10 @@
                      dynamic = False):
     if dynamic:
         from .task_queue import dynamic_parallel_objects
-        dynamic_parallel_objects(objects, njobs=njobs,
-                                 storage=storage)
+        for my_obj in dynamic_parallel_objects(objects, njobs=njobs,
+                                               storage=storage):
+            yield my_obj
+        return
     
     if not parallel_capable:
         njobs = 1


diff -r c5d54e6e4232b812e4754e926318aa0c5f60d587 -r e25bbbcec539a5cb2bd4810da8bbc268f208043b yt/utilities/parallel_tools/task_queue.py
--- a/yt/utilities/parallel_tools/task_queue.py
+++ b/yt/utilities/parallel_tools/task_queue.py
@@ -63,7 +63,7 @@
             msg = self.comm.comm.recv(source = 0, tag=2)
         msg = self.subcomm.bcast(msg, root=0)
         if msg['msg'] == messages['end']['msg']:
-            mylog.info("Notified to end")
+            mylog.debug("Notified to end")
             raise StopIteration
         return msg['value']

Repository URL: https://bitbucket.org/yt_analysis/yt/

--

This is a commit notification from bitbucket.org. You are receiving
this because you have the service enabled, addressing the recipient of
this email.