156 def mailfailure(jobname, job, message):  argument
176     mail.send("", job.user, "", subject, message_header + message)
307 def export_tko_job_to_file(job, jobname, filename):  argument
317     serializer.serialize_to_binary(job, jobname, filename)
344     job_keyval = models.job.read_keyval(path)
348     job = parser.make_job(path)
354     _parse_status_log(parser, job, status_log_path)
357         job.job_idx = old_job_idx
358         unmatched_tests = _match_existing_tests(db, job)
362     job.afe_job_id = tko_utils.get_afe_job_id(jobname)
363     job.skylab_task_id = tko_utils.get_skylab_task_id(jobname)
364     job.afe_parent_job_id = job_keyval.get(constants.PARENT_JOB_ID)
365     job.skylab_parent_task_id = job_keyval.get(constants.PARENT_JOB_ID)
366     job.build = None
367     job.board = None
368     job.build_version = None
369     job.suite = None
370     if job.label:
371         label_info = site_utils.parse_job_name(job.label)
373             job.build = label_info.get('build', None)
374             job.build_version = label_info.get('build_version', None)
375             job.board = label_info.get('board', None)
376             job.suite = label_info.get('suite', None)
387     job.keyval_dict.update(result_size_info.__dict__)
394     for test in job.tests:
413                                 % (jobname, job.user))
414             mailfailure(jobname, job, message)
417         for test in job.tests:
418             perf_uploader.upload_test(job, test, jobname)
421         sponge_url = sponge_utils.upload_results(job, log=tko_utils.dprint)
423             job.keyval_dict['sponge_url'] = sponge_url
425         _write_job_to_db(db, jobname, job)
428         if job.tests:
429             tests_in_db = db.find_tests(job.job_idx)
431             if tests_in_db_count != len(job.tests):
435                         (job.job_idx, len(job.tests), tests_in_db_count))
453             _invalidate_original_tests(orig_job_idx, job.job_idx)
461         export_tko_job_to_file(job, jobname, binary_file_name)
473         and job.suite and datastore_parent_key):
478                     (common.autotest_dir, job.afe_job_id,
521 def _write_job_to_db(db, jobname, job):  argument
530     db.insert_or_update_machine(job)
531     db.insert_job(jobname, job)
533             job,
536     db.update_job_keyvals(job)
537     for test in job.tests:
538         db.insert_test(job, test)
549 def _parse_status_log(parser, job, status_log_path):  argument
551     parser.start(job)
555     job.tests = []
560             job.tests.append(test)
563 def _match_existing_tests(db, job):  argument
568     old_job_idx = job.job_idx
577     for test in job.tests: