Classes | |
class | JobAttemptSummary |
Functions | |
def | ParseLogEntry |
def python::JobAttemptSummary::ParseLogEntry | ( | log_line | ) |
Parse global log file line entry holding job submission information. For valid entries returns a tuple containing:- log_ut Log file line Unix time jas_id Job submission entry: <task>.<job-try-id> event Data recorded on line For invalid entries: return None.
Definition at line 12 of file JobAttemptSummary.py.
00012 : 00013 """Parse global log file line entry holding job submission information. 00014 00015 For valid entries returns a tuple containing:- 00016 00017 log_ut Log file line Unix time 00018 jas_id Job submission entry: <task>.<job-try-id> 00019 event Data recorded on line 00020 00021 For invalid entries: return None. 00022 """ 00023 00024 mo = re.search(r'(\d\d\d\d-\d\d-\d\d \d\d:\d\d:\d\d)\s+\S+\s+\d+\s+(\S+)\s+(\S+?\d+)\s+(.+)',log_line.strip()) 00025 if not mo: return None 00026 log_ut = TimeStampToUnixTime(mo.group(1)) 00027 task = mo.group(2) 00028 try_id = mo.group(3) 00029 if try_id[0:5] == "JTID:": try_id = try_id[5:] 00030 00031 jas_id = "%s.%s" % (task,try_id) 00032 event = mo.group(4) 00033 return (log_ut,jas_id,event) 00034 00035 #_______________________________________________________________________________________________ 00036 00037 00038 class JobAttemptSummary: