@@ -44,6 +44,7 @@ on a.signature=b.signature
TidbProConn.upsert(conn=self.conn, sql_buff=sql)
self.conn.commit()
TidbProConn.conn_close(self.conn)
+ return 0
except Exception as e:
logging.error(e)
return -1