func()

in pkg/flink/handler.go [148:161]

• 11 lines of code
• 2 McCabe index (conditional complexity)

func (h flinkResourceHandler) OnAbort(ctx context.Context, tCtx pluginsCore.TaskExecutionContext, resource client.Object) (behavior k8s.AbortBehavior, err error) {
	var abortBehavior k8s.AbortBehavior

	annotationPatch, err := NewAnnotationPatch(flinkOp.ControlAnnotation, flinkOp.ControlNameJobCancel)

	if err != nil {
		logger.Error(ctx, "error observed in abort", err)
		return abortBehavior, err
	}

	patchOp := k8s.PatchResourceOperation{Patch: annotationPatch}
	abortBehavior = k8s.AbortBehaviorPatchDefaultResource(patchOp, false)
	return abortBehavior, nil
}