12

有没有办法在多个并行任务之间动态修改主机？这就是我到目前为止所拥有的。

def init_hosts():
    env.hosts = [host1,host2,host3,host4]

@parallel
def task_1():
    if condition is False:
        env.hosts.remove(env.host)

@parallel
def task_2():
    run('uname -s')

显然我缺少一些env参数，但我只想task_2在满足task_1. 似乎task_2的主机列表在启动时被初始化，因为它在env.hosts定义的初始列表中的所有主机上运行init_hosts()。我还尝试动态修改和构建角色定义，但结果相同。

编辑：另外，有没有办法设置一个并行执行队列，以便并行执行多个并行任务而不是顺序执行？

编辑：通过让每个任务返回输出并解析输出以构建一个新的主机列表以传递给 execute()，我设法获得了我想要的最终结果：

def init_hosts():
    env.hosts = [host1,host2,host3,host4]

@parallel
def task_1():
    if condition is False:
        return False
    else:
        return True

@parallel
def task_2():
   run('uname -s')

def run_tests():
   results = execute(task_1)
   successful_hosts = [k for k in results.iterkeys() if results[k]]
   execute(test_2, hosts=successful_hosts)

这行得通，但由于许多原因它很糟糕。有没有更好的办法？

4

1 回答 1

3

并行执行使用分叉，因此不共享（返回）状态更改。因此，在一个并行运行的任务中更改环境变量，不会影响该任务运行的任何其他实例，也不会更改在调用之前全局设置的任何内容。

如果 task_1 所做的只是检查，为什么不将这个逻辑合并到 task_2 中呢？

于 2012-05-15T19:54:26.627 回答