change code style

Author: esythan

models/rank/slot_dnn/inmemorydataset_reader.py

@@ -67,9 +67,10 @@ def line_process(self, line):
             if slot not in self.slots:
                 continue
             feasign = int(slot_feasign[0])
-            if feasign not in fea_dict:
-                fea_dict[feasign] = str(len(fea_dict))
-            output[self.slot2index[slot]][1].append(fea_dict[feasign])
+            # if feasign not in fea_dict:
+            #     fea_dict[feasign] = str(len(fea_dict))
+            # output[self.slot2index[slot]][1].append(fea_dict[feasign])
+            output[self.slot2index[slot]][1].append(feasign)
             self.visit[slot] = True
         for i in self.visit:
             slot = i

models/rank/slot_dnn/net.py

@@ -67,20 +67,11 @@ def forward(self, slot_inputs):
         embs = []
         self.inference_feed_vars = []
         for s_input in slot_inputs:
-            if self.sync_mode == "gpubox":
-                emb = paddle.static.nn.sparse_embedding(
-                    #emb = paddle.fluid.contrib.sparse_embedding(
-                    input=s_input,
-                    size=[self.dict_dim, self.emb_dim],
-                    param_attr=paddle.ParamAttr(name="embedding"))
-            else:
-                emb = paddle.fluid.layers.embedding(
-                    input=s_input,
-                    size=[self.dict_dim, self.emb_dim],
-                    is_sparse=True,
-                    is_distributed=True,
-                    param_attr=paddle.ParamAttr(name="embedding"))
-                #emb = self.embedding(s_input)
+            emb = paddle.static.nn.sparse_embedding(
+                #emb = paddle.fluid.contrib.sparse_embedding(
+                input=s_input,
+                size=[self.dict_dim, self.emb_dim],
+                param_attr=paddle.ParamAttr(name="embedding"))
             self.inference_feed_vars.append(emb)
 
             bow = paddle.fluid.layers.sequence_pool(input=emb, pool_type='sum')

models/rank/slot_dnn/queuedataset_reader.py

@@ -66,9 +66,10 @@ def line_process(self, line):
             if slot not in self.slots:
                 continue
             feasign = int(slot_feasign[0])
-            if feasign not in fea_dict:
-                fea_dict[feasign] = len(fea_dict)
-            output[self.slot2index[slot]][1].append(fea_dict[feasign])
+            # if feasign not in fea_dict:
+            #     fea_dict[feasign] = len(fea_dict)
+            # output[self.slot2index[slot]][1].append(fea_dict[feasign])
+            output[self.slot2index[slot]][1].append(feasign)
             self.visit[slot] = True
         for i in self.visit:
             slot = i

tools/utils/static_ps/flow_helper.py

@@ -139,7 +139,7 @@ def save_inference_model(exe,
     """
     day = str(day)
     pass_id = str(pass_id)
-    suffix_name = "/%s/%s/inference_model/" % (day, pass_id)
+    suffix_name = "/%s/inference_model_%s/" % (day, pass_id)
     model_path = output_path + suffix_name
     logger.info("going to save_inference_model %s" % model_path)
     fleet.save_inference_model(