fix(go/adbc/driver/flightsql): take metadata lock for safety (#1228)

Fixes #1178.
apache · Oct 26, 2023 · 1bd874b · 1bd874b
1 parent 4a34896
commit 1bd874b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/go/adbc/driver/flightsql/flightsql_database.go b/go/adbc/driver/flightsql/flightsql_database.go
@@ -382,7 +382,8 @@ func getFlightClient(ctx context.Context, loc string, d *databaseImpl) (*flights
 		}
 
 		if md, ok := metadata.FromOutgoingContext(ctx); ok {
-			// No need to worry about lock here since we are sole owner
+			authMiddle.mutex.Lock()
+			defer authMiddle.mutex.Unlock()
 			authMiddle.hdrs.Set("authorization", md.Get("Authorization")[0])
 		}
 	}