Fix pipileInfo pipeLineInfo (#66673)

co63oc · web-flow · commit 319500dac2b4 · 2024-09-20T14:27:18.000+08:00
* Fix

* Fix

* ci
diff --git a/tools/CrossStackProfiler/CspReporter.py b/tools/CrossStackProfiler/CspReporter.py
@@ -166,14 +166,14 @@ def _set_timeInfo(self, timeFileNamePrefix="time.txt", sed="."):
                 self._timeInfo[gpuId * trainerId] = info
 
     def _generateTraceFileByGroupAndGpuId(
-        self, pipileInfo, netInfo, groupId, gpuId
+        self, pipeLineInfo, netInfo, groupId, gpuId
     ):
         dcgmInfoDict = self._dcgmFileReader.getDcgmInfoDict(groupId, gpuId)
         opInfoDict = self._profileFileReader.getOpInfoDict(groupId, gpuId)
 
         traceObj = {}
         traceObj["traceEvents"] = (
-            pipileInfo[str(gpuId)]
+            pipeLineInfo[str(gpuId)]
             + opInfoDict["traceEvents"]
             + dcgmInfoDict["traceEvents"]
             + netInfo["traceEvents"]
@@ -185,7 +185,7 @@ def _generateTraceFileByGroupAndGpuId(
 
     def _generateTraceFileByGroup(self, groupId, processNum):
         # first we need to generate pipeline info
-        pipileInfo = self._profileFileReader.getPipeLineInfo(
+        pipeLineInfo = self._profileFileReader.getPipeLineInfo(
             groupId, processNum
         )
         # second we need to generate dcgm info
@@ -207,7 +207,7 @@ def _generateTraceFileByGroup(self, groupId, processNum):
             subproc = Process(
                 target=self._generateTraceFileByGroupAndGpuId,
                 args=(
-                    pipileInfo,
+                    pipeLineInfo,
                     netInfo,
                     groupId,
                     gpuId,
diff --git a/tools/CrossStackProfiler/NetFileReader.py b/tools/CrossStackProfiler/NetFileReader.py
@@ -111,10 +111,10 @@ def parseFileByGroup(self, groupId, processNum=8):
             )
 
         traceInfo = {}
-        isFistProcess = True
+        isFirstProcess = True
         for t in processPool:
-            if isFistProcess:
-                isFistProcess = False
+            if isFirstProcess:
+                isFirstProcess = False
                 traceInfo["traceEvents"] = q.get()["traceEvents"]
             else:
                 traceInfo["traceEvents"].extend(q.get()["traceEvents"])
diff --git a/tools/get_pr_ut.py b/tools/get_pr_ut.py
@@ -276,7 +276,7 @@ def get_all_count(self):
                 all_counts = line.split()[-1]
         return int(all_counts)
 
-    def file_is_unnit_test(self, unittest_path):
+    def file_is_unit_test(self, unittest_path):
         # get all testcases by ctest-N
         all_ut_file = PADDLE_ROOT + 'build/all_ut_list'
         # all_ut_file = '%s/build/all_ut_file' % PADDLE_ROOT
@@ -320,7 +320,7 @@ def get_pr_ut(self):
         filterFiles = []
         file_list = []
         file_dict = self.get_pr_files()
-        if len(file_dict) == 30:  # if pr file count = 31, nend to run all case
+        if len(file_dict) == 30:  # if pr file count = 31, need to run all case
             return ''
         for filename in file_dict:
             if filename.startswith(PADDLE_ROOT + 'python/'):
@@ -425,7 +425,7 @@ def get_pr_ut(self):
                             if self.is_only_comment(f):
                                 ut_list.append('comment_placeholder')
                                 onlyCommentsFilesOrXpu.append(f_judge)
-                            if self.file_is_unnit_test(f_judge):
+                            if self.file_is_unit_test(f_judge):
                                 ut_list.append(
                                     os.path.split(f_judge)[1].split(".")[0]
                                 )
diff --git a/tools/get_single_test_cov.py b/tools/get_single_test_cov.py
@@ -37,7 +37,7 @@ def getFNDAFile(rootPath, test):
     os.system(f'touch {fn_filename}')
     try:
         f = open(filename)
-        print(f"oepn {filename} successfully")
+        print(f"open {filename} successfully")
     except FileNotFoundError:
         print(f"{filename} is not found.")
         return
diff --git a/tools/get_ut_file_map.py b/tools/get_ut_file_map.py
@@ -18,7 +18,7 @@
 
 
 def get_all_paddle_file(rootPath):
-    """get all file in Paddle repo: paddle/fluild, python"""
+    """get all file in Paddle repo: paddle/fluid, python"""
     traverse_files = [f'{rootPath}']
     all_file_paddle = f'{rootPath}/build/all_file_paddle'
     all_file_paddle_list = []
@@ -84,7 +84,7 @@ def handle_ut_file_map(rootPath):
             filename = f'{ut_map_path}/{ut}/related_{ut}.txt'
             try:
                 f = open(filename)
-                print(f"oepn {filename} succesfully")
+                print(f"open {filename} successfully")
             except FileNotFoundError:
                 print(f"{filename} is not found.")
                 return
@@ -120,7 +120,7 @@ def handle_ut_file_map(rootPath):
             filename = f'{ut_map_path}/{ut}/notrelated_{ut}.txt'
             try:
                 f = open(filename)
-                print(f"oepn {filename} succesfully")
+                print(f"open {filename} successfully")
             except FileNotFoundError:
                 print(f"{filename} is not found.")
             lines = f.readlines()
