def METHOD_NAME():
    @job
    def diamond_job():
        return_one()
        return_two()
    result = diamond_job.execute_in_process()
    assert result.output_for_node("return_one") == 1
    assert result.output_for_node("return_two") == 2