小编dj2*_*j29的帖子

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

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().我也尝试动态修改和构建roledef,但结果相同.

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

编辑:我设法通过让每个任务返回输出来获得我想要的最终结果,并解析输出以构建新的主机列表以传递给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)

这有效,但由于很多原因,这很糟糕.有没有更好的办法？