for m in r:
                mo = m['mo']
                go = []
                commands = m['config'].split('\n')
                task = ReduceTask.create_task(object_selector=mo,
                                              map_script="commands",
                                              map_script_params={"commands":commands},
                                              reduce_script="pyrule:mrt_result",
                                              reduce_script_params={},
                                              timeout=120)
                while not task.complete:
                    sleep(0.3)