Browse Source

add flight err back (#895)

Zhixin Wen 8 years ago
parent
commit
7e9748ccda
1 changed files with 1 additions and 0 deletions
  1. 1 0
      conn.go

+ 1 - 0
conn.go

@@ -711,6 +711,7 @@ func (c *Conn) prepareStatement(ctx context.Context, stmt string, tracer Tracer)
 
 	framer, err := c.exec(ctx, prep, tracer)
 	if err != nil {
+		flight.err = err
 		flight.wg.Done()
 		c.session.stmtsLRU.remove(stmtCacheKey)
 		return nil, err