@@ -385,7 +385,8 @@ class MysqlHelper(object):
conn.commit()
except pymysql.MySQLError as e:
print(f"Error in batch_insert: {e}")
- connection.rollback()
+ conn.rollback()
+ raise e
conn.close()