|
@@ -848,7 +848,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
|
|
#process succeed
|
|
#process succeed
|
|
dtmp.setValue(document_tmp_dochtmlcon,"",False)
|
|
dtmp.setValue(document_tmp_dochtmlcon,"",False)
|
|
dtmp.setValue(document_tmp_status,random.randint(*flow_extract_status_succeed_to),True)
|
|
dtmp.setValue(document_tmp_status,random.randint(*flow_extract_status_succeed_to),True)
|
|
- if _docid==291120546:
|
|
|
|
|
|
+ if _docid==290816703:
|
|
dtmp.setValue("test_json",extract_json,True)
|
|
dtmp.setValue("test_json",extract_json,True)
|
|
dtmp.update_row(self.ots_client)
|
|
dtmp.update_row(self.ots_client)
|
|
dhtml.update_row(self.ots_client)
|
|
dhtml.update_row(self.ots_client)
|