[yt-dev] missing objects using parallel_objects()

[Stephen Skory]

Hi Geoffrey,

It looks like the parallel_objects storage doesn't like it when
result_id is a float. So you have this:

for sto, halo in parallel_objects(haloes, num_procs, storage = my_storage):

    sto.result_id = halo.total_mass()
    sto.result = na.array([0])

And when I try this on my own data, I do see a deficit of items in
my_storage. But I do this instead:

for sto, halo in parallel_objects(haloes, 0, storage = my_storage):
    sto.result_id = halo.id
    sto.result = (halo.total_mass(), na.array([0]))

I get the correct number of items in my_storage. I hope this helps!

-- 
Stephen Skory
s at skory.us
http://stephenskory.com/
510.621.3687 (google voice)