Call configure in sequence (not in parallel)

pulumi · Dec 12, 2024 · 9955bde · 9955bde
1 parent e53958b
commit 9955bde
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/pkg/x/muxer/muxer.go b/pkg/x/muxer/muxer.go
@@ -291,13 +291,13 @@ func (m *muxer) DiffConfig(ctx context.Context, req *pulumirpc.DiffRequest) (*pu
 func (m *muxer) Configure(ctx context.Context, req *pulumirpc.ConfigureRequest) (*pulumirpc.ConfigureResponse, error) {
 	// Configure determines what the values the provider understands. We take the
 	// `and` of configure values.
-	subs := make([]func() tuple[*pulumirpc.ConfigureResponse, error], len(m.servers))
+	results := make([]tuple[*pulumirpc.ConfigureResponse, error], len(m.servers))
 	for i, s := range m.servers {
 		i, s := i, s
-		subs[i] = func() tuple[*pulumirpc.ConfigureResponse, error] {
+		results[i] = func() tuple[*pulumirpc.ConfigureResponse, error] {
 			req := proto.Clone(req).(*pulumirpc.ConfigureRequest)
 			return newTuple(s.Configure(ctx, req))
-		}
+		}()
 	}
 	response := &pulumirpc.ConfigureResponse{
 		AcceptSecrets:   true,
@@ -306,7 +306,7 @@ func (m *muxer) Configure(ctx context.Context, req *pulumirpc.ConfigureRequest)
 		AcceptOutputs:   true,
 	}
 	errs := new(multierror.Error)
-	for _, r := range asyncJoin(subs) {
+	for _, r := range results {
 		if r.B != nil {
 			errs.Errors = append(errs.Errors, r.B)
 			continue