(org params.Organization)
| 459 | } |
| 460 | |
| 461 | func (r *Runner) createAndStartOrgPoolManager(org params.Organization) { |
| 462 | slog.InfoContext(r.ctx, "creating pool manager for organization", "org_name", org.Name) |
| 463 | poolMgr, err := r.poolManagerCtrl.CreateOrgPoolManager(r.ctx, org, r.providers, r.store) |
| 464 | if err != nil { |
| 465 | slog.ErrorContext(r.ctx, "creating org pool manager", "org_name", org.Name, "error", err) |
| 466 | r.failedEntities[org.ID] = failedEntity{entityType: params.ForgeEntityTypeOrganization, id: org.ID} |
| 467 | r.backoff.RecordFailure(org.ID) |
| 468 | return |
| 469 | } |
| 470 | if err := poolMgr.Start(); err != nil { |
| 471 | slog.ErrorContext(r.ctx, "starting org pool manager", "org_name", org.Name, "error", err) |
| 472 | if deleteErr := r.poolManagerCtrl.DeleteOrgPoolManager(org); deleteErr != nil { |
| 473 | slog.ErrorContext(r.ctx, "cleaning up failed org pool manager", "org_id", org.ID, "error", deleteErr) |
| 474 | } |
| 475 | r.failedEntities[org.ID] = failedEntity{entityType: params.ForgeEntityTypeOrganization, id: org.ID} |
| 476 | r.backoff.RecordFailure(org.ID) |
| 477 | return |
| 478 | } |
| 479 | delete(r.failedEntities, org.ID) |
| 480 | r.backoff.RecordSuccess(org.ID) |
| 481 | } |
| 482 | |
| 483 | func (r *Runner) createAndStartEnterprisePoolManager(enterprise params.Enterprise) { |
| 484 | slog.InfoContext(r.ctx, "creating pool manager for enterprise", "enterprise_name", enterprise.Name) |
no test coverage detected