@@ -1443,6 +1443,8 @@ func (api *API) CreateInMemoryProvisionerDaemon(dialCtx context.Context, name st
1443
1443
return api .CreateInMemoryTaggedProvisionerDaemon (dialCtx , name , provisionerTypes , nil )
1444
1444
}
1445
1445
1446
+ var i int
1447
+
1446
1448
func (api * API ) CreateInMemoryTaggedProvisionerDaemon (dialCtx context.Context , name string , provisionerTypes []codersdk.ProvisionerType , provisionerTags map [string ]string ) (client proto.DRPCProvisionerDaemonClient , err error ) {
1447
1449
tracer := api .TracerProvider .Tracer (tracing .TracerName )
1448
1450
clientSession , serverSession := drpc .MemTransportPipe ()
@@ -1453,12 +1455,16 @@ func (api *API) CreateInMemoryTaggedProvisionerDaemon(dialCtx context.Context, n
1453
1455
}
1454
1456
}()
1455
1457
1458
+ orgs , _ := api .Database .GetOrganizations (context .Background ())
1459
+ defaultOrg := orgs [i % len (orgs )]
1460
+ i ++
1461
+
1456
1462
// All in memory provisioners will be part of the default org for now.
1457
1463
//nolint:gocritic // in-memory provisioners are owned by system
1458
- defaultOrg , err := api .Database .GetDefaultOrganization (dbauthz .AsSystemRestricted (dialCtx ))
1459
- if err != nil {
1460
- return nil , xerrors .Errorf ("unable to fetch default org for in memory provisioner: %w" , err )
1461
- }
1464
+ // defaultOrg, err := api.Database.GetDefaultOrganization(dbauthz.AsSystemRestricted(dialCtx))
1465
+ // if err != nil {
1466
+ // return nil, xerrors.Errorf("unable to fetch default org for in memory provisioner: %w", err)
1467
+ // }
1462
1468
1463
1469
dbTypes := make ([]database.ProvisionerType , 0 , len (provisionerTypes ))
1464
1470
for _ , tp := range provisionerTypes {
0 commit comments