func (m *Manager) RequeueWorkload(ctx context.Context, info *workload.Info) bool {
	m.Lock()
	defer m.Unlock()

	q := m.queues[queueKeyForWorkload(info.Obj)]
	if q == nil {
		return false
	}

	var w kueue.QueuedWorkload
	err := m.client.Get(ctx, client.ObjectKeyFromObject(info.Obj), &w)
	// Since the client is cached, the only possible error is NotFound
	if apierrors.IsNotFound(err) {
		return false
	}

	key := workload.Key(info.Obj)
	q.items[key] = info

	cq := m.clusterQueues[q.ClusterQueue]
	if cq == nil {
		return false
	}
	return cq.PushIfNotPresent(info)
}
// RequeueWorkload requeues the workload ensuring that the queue and the
// workload still exist in the client cache. It won't requeue if the workload
// is already in the queue (possible if the workload was updated).
RequeueWorkload requeues the workload ensuring that the queue and the
workload still exist in the client cache. It won't requeue if the workload
is already in the queue (possible if the workload was updated).
// RequeueWorkload requeues the workload ensuring that the queue and the // workload still exist in the client cache . It won ' t requeue if the workload // is already in the queue ( possible if the workload was updated ) .
func (m *Manager) RequeueWorkload(ctx context.Context, info *workload.Info) bool {
	m.Lock()
	defer m.Unlock()
	q := m.queues[queueKeyForWorkload(info.Obj)]
	if q == nil {
		return false
	}
	var w kueue.QueuedWorkload
	err := m.client.Get(ctx, client.ObjectKeyFromObject(info.Obj), &w)
	if apierrors.IsNotFound(err) {
		return false
	}
	key := workload.Key(info.Obj)
	q.items[key] = info
	cq := m.clusterQueues[q.ClusterQueue]
	if cq == nil {
		return false
	}
	return cq.PushIfNotPresent(info)
}
func ( m * Manager ) RequeueWorkload ( ctx context . Context , info * workload . Info ) bool { m . Lock ( ) defer m . Unlock ( ) q := m . queues [ queueKeyForWorkload ( info . Obj ) ] if q == nil { return false } var w kueue . QueuedWorkload err := m . client . Get ( ctx , client . ObjectKeyFromObject ( info . Obj ) , & w ) if apierrors . IsNotFound ( err ) { return false } key := workload . Key ( info . Obj ) q . items [ key ] = info cq := m . clusterQueues [ q . ClusterQueue ] if cq == nil { return false } return cq . PushIfNotPresent ( info ) }
RequeueWorkload requeues the workload ensuring that the queue and the
workload still exist in the client cache.
RequeueWorkload requeues the workload ensuring that the queue and the workload still exist in the client cache .
// Since the client is cached, the only possible error is NotFound