Removed the WorkflowBenchmark::run() now obsolete method

Author: henricasanova

wfcommons/wfbench/bench.py

@@ -634,115 +634,6 @@ def generate_input_file(self, path: pathlib.Path) -> None:
         path.write_text(json.dumps(inputs, indent=2))
         input("Please fill up the input file and press ENTER to continue...")
 
-    def run(self, json_path: pathlib.Path, save_dir: pathlib.Path) -> None:
-        """
-        Run the benchmark workflow locally (for test purposes only).
-
-        :param json_path:
-        :type json_path: pathlib.Path
-        :param: save_dir:
-        :type save_dir: pathlib.Path
-        """
-        self.logger.debug("Running")
-
-        try:
-            wf = json.loads(json_path.read_text())
-            with save_dir.joinpath(f"run.txt").open("w+") as fp:
-                print("Starting run...")
-                has_executed: Set[str] = set()
-                procs: List[subprocess.Popen] = []
-                print("Workflow tasks:", len(wf["workflow"]["specification"]["tasks"]))
-                print("Has executed:", len(has_executed))
-
-                while len(has_executed) < len(wf["workflow"]["specification"]["tasks"]):
-                    print("In while loop")
-                    for task in wf["workflow"]["specification"]["tasks"]:
-                        input_files = {}
-                        if task["name"] in has_executed:
-                            print(f'{task["name"]} has executed...')
-                            continue
-                        
-                        # Collect input files 
-                        for input_file_name in task["inputFiles"]:
-                            input_files["name"] = input_file_name
-                            
-                            for entry in wf["workflow"]["specification"]["files"]:
-                                if input_file_name in entry["id"]:
-                                    print(f"Entry: {entry}")    
-                                    sizeInBytes = entry[input_file_name]["sizeInBytes"]
-                                    input_files[input_file_name]["size"] = sizeInBytes
-
-                        # Generate the input files
-                        if input_files:
-                            print(f"Creating files: {input_files}")
-                            generate_sys_data(num_files=1,
-                                              tasks=input_files,
-                                              save_dir=save_dir)                            
-                        
-                        real_file_names = [f"{save_dir.joinpath(input_file)}" for input_file in input_files]
-                        if ready_to_execute := all([
-                            pathlib.Path(input_file).exists()
-                            for input_file in real_file_names
-                        ]):
-                            print("Ready to execute:", ready_to_execute)
-                        else:
-                            # Print the files that are not ready to execute
-                            print("Not ready to execute:", [
-                                input_file for input_file in real_file_names
-                                if not pathlib.Path(input_file).exists()
-                            ])
-                            continue
-                    
-                        print(f"Executing task: {task['name']}")
-                        has_executed.add(task["name"])
-
-                        executable = task["command"]["program"]
-                        executable = str(this_dir.parent.parent.joinpath(f"bin/{executable}"))
-                        arguments = task["command"]["arguments"]
-                        # Function to clean and adjust the list entries
-                        arguments = [clean_entry(entry) for entry in arguments]
-                                
-                        # arguments = [
-                        #     # --[opt] [value] -> --[opt]=[value]
-                        #     re.sub(r'--(.*?) (.*)', r'--\1=\2', argument)
-                        #     for argument in arguments
-                        # ]
-                        print("ARGUMENTS", arguments)
-
-                        for arg in arguments:
-                            if "--out" in arg:
-                                files = assigning_correct_files(task)
-                                print("FILES", files)
-                                program = ["time", "python",
-                                        executable, *arguments, *files]
-                            else:
-                                program = ["time", "python",
-                                        executable, *arguments]
-                            
-                       
-                        print("Prog:", program)
-
-                        # folder = pathlib.Path(f"wfbench_execution/{uuid.uuid4()}")
-                        # folder.mkdir(exist_ok=True, parents=True)
-                        proc = subprocess.Popen(program, stdout=fp, stderr=fp, cwd=save_dir)
-                        print(proc.args)
-                        procs.append(proc)
-
-                        print("#Tasks executed:", len(has_executed))
-                        time.sleep(1)
-                    
-                for proc in procs:
-                    proc.wait()
-
-            cleanup_sys_files()
-
-        except Exception as e:
-            subprocess.Popen(["killall", "stress-ng"])
-            cleanup_sys_files()
-            import traceback
-            traceback.print_exc()
-            raise FileNotFoundError("Not able to find the executable.")
-
 
 def generate_sys_data(num_files: int, tasks: Dict[str, int], save_dir: pathlib.Path) -> None:
     """Generate workflow's input data