File tree Expand file tree Collapse file tree 1 file changed +2
-11
lines changed
Expand file tree Collapse file tree 1 file changed +2
-11
lines changed Original file line number Diff line number Diff line change 55import multiprocessing as mp
66from enum import Enum
77from pathlib import Path
8- from typing import Any , List , Tuple
8+ from typing import List , Tuple
99
1010import pandas as pd
1111import psutil
@@ -228,16 +228,7 @@ def normalize_gpu_stream_numbers(df: pd.DataFrame) -> None:
228228 logger .error ("No stream column found in the trace." )
229229 return
230230
231- def _normalize_stream_number (stream_number : Any ) -> int :
232- try :
233- return int (stream_number )
234- except ValueError :
235- return - 1
236-
237- df ["stream" ] = df .apply (
238- lambda r : _normalize_stream_number (r ["stream" ]),
239- axis = 1 ,
240- )
231+ df ["stream" ] = pd .to_numeric (df ["stream" ], errors = "coerce" ).fillna (- 1 ).astype (int )
241232
242233
243234def get_value_from_dict (d : object , key : str , default : object = None ) -> object :
You can’t perform that action at this time.
0 commit comments