c10201a4271f46bcf35decd8c8ca9e27ddf00bea,horovod/run/common/util/safe_shell_exec.py,,terminate_executor_shell_and_children,#Any#,30

Before Change

            pass

    // Kill shell itself.
    p.kill()


def forward_stream(src_fd, dst_stream, prefix, index):

After Change

    try:
        p.wait(timeout=GRACEFUL_TERMINATION_TIME_S)
    except psutil.TimeoutExpired:
        try:
            p.kill()
        except psutil.NoSuchProcess:
            pass


def forward_stream(src_stream, dst_stream, prefix, index):
    def prepend_context(line, rank, prefix):
        localtime = time.asctime(time.localtime(time.time()))
        return "{time}[{rank}]<{prefix}>:{line}".format(

Instances