AsyncResult - hazard distribute calculations

$ ./bin/openquake --run-hazard=./demos/hazard/SimpleFaultSourceClassicalPSHA/job.ini
[2014-01-29 22:53:48,163 hazard #248 - PROGRESS MainProcess/5405 root] **  pre_executing (hazard)
[2014-01-29 22:53:48,166 hazard #248 - PROGRESS MainProcess/5405 root] **  initializing sites
[2014-01-29 22:53:48,801 hazard #248 - PROGRESS MainProcess/5405 root] **  initializing sources
[2014-01-29 22:53:49,126 hazard #248 - PROGRESS MainProcess/5405 root] **  initializing realizations
[2014-01-29 22:53:49,149 hazard #248 - PROGRESS MainProcess/5405 root] **  executing (hazard)
[2014-01-29 22:53:50,195 hazard #248 - WARNING MainProcess/5405 root] Using block size=1
[2014-01-29 22:53:50,195 hazard #248 - PROGRESS MainProcess/5405 root] **  spawning 1 tasks of kind compute_hazard_curves
[2014-01-29 22:53:50,230 hazard #248 - CRITICAL MainProcess/5405 root] Calculation failed with exception: ''AsyncResult' object is not iterable'
Traceback (most recent call last):
  File "./bin/openquake", line 476, in <module>
    main()
  File "./bin/openquake", line 428, in main
    log_file, args.exports)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/engine.py", line 633, in run_hazard
    job, log_level, log_file, exports, 'hazard'
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/engine.py", line 447, in run_calc
    _job_exec(job, log_level, exports, job_type, calc)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/engine.py", line 472, in _job_exec
    _do_run_calc(job, exports, calc, job_type)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/engine.py", line 513, in _do_run_calc
    calc.execute()
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/calculators/base.py", line 152, in execute
    self.task_completed)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/calculators/base.py", line 102, in parallelize
    tasks.parallelize(task_func, arglist, task_completed)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/utils/tasks.py", line 86, in parallelize
    map_reduce(task, task_args, lambda acc, val: side_effect(val), None)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/utils/tasks.py", line 65, in map_reduce
    acc = agg(acc, result)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/utils/tasks.py", line 86, in <lambda>
    map_reduce(task, task_args, lambda acc, val: side_effect(val), None)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/performance.py", line 120, in newmeth
    return method(self, *args)
  File "/Users/pirchiner/dev/oq-engine/openquake/engine/calculators/hazard/classical/core.py", line 159, in task_completed
    curves_by_imt, i = task_result
TypeError: 'AsyncResult' object is not iterable