|
@@ -5257,7 +5257,7 @@ class Dataflow_dumplicate(Dataflow):
|
|
|
log("start dumplicate_comsumer_handle")
|
|
|
self.dumplicate_comsumer_handle(item,None,self.ots_client,get_all=False,upgrade=False)
|
|
|
# self.dumplicate_comsumer_handle(item,None,self.ots_client,get_all=True,upgrade=False)
|
|
|
-
|
|
|
+ return
|
|
|
|
|
|
def test_merge(self,list_docid_less,list_docid_greater):
|
|
|
list_docs_less = self.search_docs(list_docid_less)
|