def run(self, number, should_die=False, wait_seconds=0):
        if wait_seconds > 0:
            yield timer_worker.TimerItem(wait_seconds)
        if should_die:
            try:
                yield EchoChild(number, should_die=should_die)
            except Exception, e:
                raise e
        raise workers.Return(number)
dataset/ETHPy150Open bslatkin/dpxdt/tests/workers_test.py/EchoChildWorkflow.run/original