o ÔÙ¾iôã@sdZdd„ZdS)aÈ(\(\w+ pid=(?P\d+)(?:,\s*ip=(?P[\d\.]+))?\))?\s*\[(?P\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2})(?:\s+DP(?P\d+))?(?:\s+TP(?P\d+))?(?:\s+EP(?P\d+))?(?:\s+PP(?P\d+))?\]\s+Decode batch( \[\d+\])?,\s+#running-req:\s*(?P\d+),\s+#token:\s*(?P\d+),\s+token usage:\s*(?P[0-9.]+),\s+.*?gen throughput \(token/s\):\s*(?P[0-9.]+),\s+#queue-req:\s*(?P\d+),csÜddl‰ˆ t| ¡d¡‰ˆjˆ d¡j t¡d‰ˆ d¡‰ˆ ˆ d¡ ¡¡‰ˆjˆ d¡j ˆj d¡g‡‡fd d „dˆjfdˆjfd ˆjfdˆjfdˆjfdˆjfdˆjfdˆjfdˆjfdˆjff Dƒ¢RŽ‰ˆS)Né)Úliner)ÚinforÚgen_throughputÚtimez%Y-%m-%d %H:%M:%Scs*g|]\}}|ˆjvrˆ |¡ |¡‘qS©)ÚcolumnsÚcolÚcast)Ú.0rÚdtype©ÚdfÚplrúU/home/ubuntu/.local/lib/python3.10/site-packages/sglang/srt/debug_utils/log_parser.pyÚ s ó zparse..ÚpidÚdp_rankÚtp_rankÚep_rankÚpp_rankÚnum_running_reqÚ num_tokenÚtoken_usageÚ queue_req)ÚpolarsÚ DataFrameÚdictÚ splitlinesÚwith_columnsrÚstrÚextract_groupsÚ_PATTERN_DECODEÚunnestÚfilterÚis_not_nullÚstrptimeÚDatetimeÚInt64ÚFloat64)ÚlinesrrrÚparses. ÿöþþr*N)r!r*rrrrÚsÿ