Method deleteInstanceFromProvider

runner/pool/pool.go:1543–1576

(ctx context.Context, instance params.Instance)

}

func (r *basePoolManager) deleteInstanceFromProvider(ctx context.Context, instance params.Instance) error {
	pool, err := r.store.GetEntityPool(r.ctx, r.entity, instance.PoolID)
	if err != nil {
		return fmt.Errorf("error fetching pool: %w", err)
	}

	provider, ok := r.providers[instance.ProviderName]
	if !ok {
		return fmt.Errorf("unknown provider %s for pool %s", instance.ProviderName, instance.PoolID)
	}

	identifier := instance.ProviderID
	if identifier == "" {
		// provider did not return a provider ID?
		// try with name
		identifier = instance.Name
	}

	slog.DebugContext(
		ctx, "calling delete instance on provider",
		"runner_name", instance.Name,
		"provider_id", identifier)

	deleteInstanceParams := common.DeleteInstanceParams{
		DeleteInstanceV011: common.DeleteInstanceV011Params{
			ProviderBaseParams: r.getProviderBaseParams(pool),
		},
	}
	if err := provider.DeleteInstance(ctx, identifier, deleteInstanceParams); err != nil {
		return fmt.Errorf("error removing instance: %w", err)
	}

	return nil
}

func (r *basePoolManager) sleepWithCancel(sleepTime time.Duration) (canceled bool) {
	if sleepTime == 0 {