[Findit] Refactoring WfTryJobData into BaseTryJobData, WfTryJobData, and FlakeTryJobData

appengine/findit/waterfall/schedule_try_job_pipeline.py

Index: appengine/findit/waterfall/schedule_try_job_pipeline.py
diff --git a/appengine/findit/waterfall/schedule_try_job_pipeline.py b/appengine/findit/waterfall/schedule_try_job_pipeline.py
index bae8b08946415c40ea914b4ac9fd357dfafc9fa3..6517ff1bc2eda7294c8d7d12ded2dc9541fa4d8d 100644
--- a/appengine/findit/waterfall/schedule_try_job_pipeline.py
+++ b/appengine/findit/waterfall/schedule_try_job_pipeline.py
@@ -6,8 +6,6 @@ from common.pipeline_wrapper import BasePipeline
 from common.pipeline_wrapper import pipeline
 from common.waterfall import buildbucket_client
 from common.waterfall import failure_type
-from model.wf_try_job import WfTryJob
-from model.wf_try_job_data import WfTryJobData
 from waterfall import buildbot
 from waterfall import waterfall_config
 
@@ -50,18 +48,6 @@ class ScheduleTryJobPipeline(BasePipeline):
 
     return build.id
 
-  def _CreateTryJobData(
-      self, build_id, master_name, builder_name, build_number, try_job_type,
-      has_compile_targets, has_heuristic_results):

[chanli, 2017/01/07 02:39:39]

I assume we can still keep this function and share it for all 3
schedule_xx_try_job_pipeline ?

[lijeffrey, 2017/01/09 19:04:01]

I think this function is different enough for all 3 we should keep them
separate: for example, all 3 have different types, flake try jobs create a
different entity type and don't have build_number, compile_targets, or
heuristic_results. I think refactoring it into a common base function and 3
separate compile/test/flake functions to handle the type-specific set up may
actually make the code harder to follow.

-    try_job_data = WfTryJobData.Create(build_id)
-    try_job_data.master_name = master_name
-    try_job_data.builder_name = builder_name
-    try_job_data.build_number = build_number
-    try_job_data.try_job_type = try_job_type
-    try_job_data.has_compile_targets = has_compile_targets
-    try_job_data.has_heuristic_results = has_heuristic_results
-    try_job_data.put()
-
   # Arguments number differs from overridden method - pylint: disable=W0221
   def run(
       self, master_name, builder_name, build_number, good_revision,