32fa0613863022090e51b45dd73d3fae57e57639,test/test_remote.py,TestRemote,testTaskSpooler,#TestRemote#,121

Before Change

        out = subprocess.check_output("sos status {} -c docker.yml -q docker".format(tasks), shell=True).decode()
        self.assertGreater(out.count("running"), 1)
        // local should all be pending but we might have results from before
        subprocess.call("cd ~/.sos/tasks; rm -f {}".format(" ".join(x+".res" for x in res["pending_tasks"])), shell=True)
        // wait another 20 seconds?
        time.sleep(10)
        out = subprocess.check_output("sos status {} -c docker.yml -q docker".format(tasks), shell=True).decode()

After Change

        self.assertEqual(out.count("completed"), len(res["pending_tasks"]))

    def testTaskSpooler(self):
        subprocess.check_output("cd ~/.sos/tasks; rm -f *.res *.sh *.status", shell=True).decode()
        script = SoS_Script("""
[10]
input: for_each={"i": range(5)}
task:

Instances