@@ -261,7 +261,7 @@ func (r *WorkloadReconciler) jobSetPodsFinished(ctx context.Context, wl *kueue.W
261
261
jobSetKey := types.NamespacedName {Name : owner .Name , Namespace : wl .Namespace }
262
262
if err := r .client .Get (ctx , jobSetKey , jobSet ); err != nil {
263
263
if apierrors .IsNotFound (err ) {
264
- log .V (5 ).Info ("JobSet already deleted" )
264
+ log .V (3 ).Info ("JobSet already deleted" )
265
265
// That means the JobSet has already been deleted, along with all associated Jobs and Pods
266
266
// we should delete Slice and cleanup Workload.
267
267
return true , nil
@@ -283,7 +283,7 @@ func (r *WorkloadReconciler) jobSetPodsFinished(ctx context.Context, wl *kueue.W
283
283
284
284
for _ , pod := range pods .Items {
285
285
if ! utilpod .IsTerminated (& pod ) {
286
- log .V (5 ).Info ("Pods are still running – skipping finalization for now" )
286
+ log .V (3 ).Info ("Pods are still running – skipping finalization for now" )
287
287
return false , nil
288
288
}
289
289
}
@@ -304,7 +304,7 @@ func (r *WorkloadReconciler) finalizeWorkload(ctx context.Context, wl *kueue.Wor
304
304
return err
305
305
}
306
306
307
- log .V (5 ).Info ("Removed finalizer" )
307
+ log .V (3 ).Info ("Removed finalizer" )
308
308
309
309
return nil
310
310
}
@@ -566,7 +566,7 @@ func (h *jobSetHandler) handleEvent(ctx context.Context, obj client.Object, q wo
566
566
log := ctrl .LoggerFrom (ctx ).WithValues ("jobSet" , klog .KRef (jobSet .Namespace , jobSet .Name ))
567
567
ctrl .LoggerInto (ctx , log )
568
568
569
- log .V (5 ).Info ("Handle JobSet event" )
569
+ log .V (3 ).Info ("Handle JobSet event" )
570
570
571
571
handleEventForJobSet (ctx , h .client , jobSet , q )
572
572
}
@@ -586,7 +586,7 @@ func handleEventForJobSet(ctx context.Context, c client.Client, jobSet *jobset.J
586
586
}
587
587
588
588
if len (workloads .Items ) == 0 {
589
- log .V (5 ).Info ("No Workloads found for the JobSet – skipping handling" )
589
+ log .V (3 ).Info ("No Workloads found for the JobSet – skipping handling" )
590
590
return
591
591
}
592
592
@@ -641,14 +641,14 @@ func (h *podHandler) handleEvent(ctx context.Context, obj client.Object, q workq
641
641
)
642
642
ctrl .LoggerInto (ctx , log )
643
643
644
- log .V (5 ).Info ("Handle Pod event" )
644
+ log .V (3 ).Info ("Handle Pod event" )
645
645
646
646
jobSet := & jobset.JobSet {}
647
647
jobSetKey := types.NamespacedName {Name : jobSetName , Namespace : pod .Namespace }
648
648
err := h .client .Get (ctx , jobSetKey , jobSet )
649
649
if err != nil {
650
650
if apierrors .IsNotFound (err ) {
651
- log .V (5 ).Info ("JobSet not found" )
651
+ log .V (3 ).Info ("JobSet not found" )
652
652
} else {
653
653
log .Error (err , "Failed to get JobSet" )
654
654
}
0 commit comments