code fix

fleetrec/examples/ctr-dnn_train_cluster.yaml

@@ -41,8 +41,8 @@ train:
   reader:
     mode: "dataset"
     batch_size: 2
-    pipe_command: "python /paddle/fleetrec/models/ctr_dnn/dataset.py"
-    train_data_path: "/paddle/fleetrec/models/ctr_dnn/data/train"
+    pipe_command: "python /paddle/eleps/fleetrec/models/ctr_dnn/dataset.py"
+    train_data_path: "/paddle/eleps/fleetrec/models/ctr_dnn/data/train"
 
   model:
     models: "fleetrec.models.ctr_dnn.model"

fleetrec/examples/ctr-dnn_train_single.yaml

@@ -35,8 +35,8 @@ train:
   reader:
     mode: "dataset"
     batch_size: 2 
-    pipe_command: "python /paddle/fleetrec/models/ctr_dnn/dataset.py"
-    train_data_path: "/paddle/fleetrec/models/ctr_dnn/data/train"
+    pipe_command: "python /paddle/eleps/fleetrec/models/ctr_dnn/dataset.py"
+    train_data_path: "/paddle/eleps/fleetrec/models/ctr_dnn/data/train"
 
   model:
     models: "fleetrec.models.ctr_dnn.model"

fleetrec/models/ctr_dnn/model.py

@@ -21,7 +21,7 @@ from fleetrec.models.base import Model
 
 class Train(Model):
     def __init__(self, config):
-        super().__init__(config)
+        Model.__init__(self, config)
         self.namespace = "train.model"
 
     def input(self):

fleetrec/trainer/transpiler_trainer.py

@@ -29,7 +29,7 @@ class TranspileTrainer(Trainer):
     def __init__(self, config=None):
         Trainer.__init__(self, config)
         self.processor_register()
-
+        self.model = None
         self.inference_models = []
         self.increment_models = []
 
@@ -115,7 +115,7 @@ class TranspileTrainer(Trainer):
         models = envs.get_global_env("train.model.models")
         model_package = __import__(models, globals(), locals(), models.split("."))
         train_model = getattr(model_package, 'Train')
-        self.model = train_model()
+        self.model = train_model(None)
         context['status'] = 'init_pass'
 
     def init(self, context):