|
@@ -1207,6 +1207,7 @@ class Dataflow_init(Dataflow):
|
|
|
_data[document_tmp_status] = status
|
|
|
send_succeed = send_msg_toacmq(self.pool_mq,json.dumps(_document_html.getProperties(),cls=MyEncoder),self.mq_extract)
|
|
|
if send_succeed:
|
|
|
+ _document.setValue(document_tmp_status,1,True)
|
|
|
_document.update_row(self.ots_client)
|
|
|
else:
|
|
|
log("send_msg_error2222")
|