Function run_command

server/utils.py:103–112

(cmd: List[str], cwd: Optional[str] = None, bg: bool = False)

    process.stdout.close()

def run_command(cmd: List[str], cwd: Optional[str] = None, bg: bool = False) -> None:
    process = subprocess.Popen(" ".join(cmd), cwd=cwd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
    
    if bg:
        # Create a separate thread to handle the printing of the process's output
        threading.Thread(target=print_process_output, args=(process,), daemon=True).start()
        return process.pid
    else:
        print_process_output(process)
        assert process.wait() == 0

def get_ckpt_names_with_node_info(workflow_json: Union[Dict, List], is_windows: bool) -> List[ModelFileWithNodeInfo]:
    ckpt_names = []