|
@@ -4325,6 +4325,7 @@ class Dataflow_dumplicate(Dataflow):
|
|
|
|
|
|
if upgrade:
|
|
|
# print(dtmp.getProperties())
|
|
|
+ dmp_docid = dmp_docid.replace(",,",",")
|
|
|
dtmp.setValue(document_tmp_dup_docid,dmp_docid,True)
|
|
|
dtmp.setValue(document_tmp_best_docid,best_docid,True)
|
|
|
_flag = dtmp.update_row(self.ots_client)
|
|
@@ -4877,7 +4878,7 @@ if __name__ == '__main__':
|
|
|
# test_attachment_interface()
|
|
|
df_dump = Dataflow_dumplicate(start_delete_listener=False)
|
|
|
# df_dump.start_flow_dumplicate()
|
|
|
- df_dump.test_dumplicate(597760933
|
|
|
+ df_dump.test_dumplicate(597788422
|
|
|
)
|
|
|
# compare_dumplicate_check()
|
|
|
# df_dump.test_merge([391898061
|