set RPO to cron duration if it is not present

cmd/integration/make_backup/main.go

@@ -466,6 +466,10 @@ func main() {
 		log.Panicf("schedule and listed schedule ids does not match: %s, %s", schedules.Schedules[0].Id, schedule.Id)
 	}
 
+	if schedules.Schedules[0].ScheduleSettings.RecoveryPointObjective.AsDuration() != time.Minute {
+		log.Panicf("wrong recovery point objective: %v", schedules.Schedules[0].ScheduleSettings.RecoveryPointObjective)
+	}
+
 	newScheduleName := "schedule-2.0"
 	newSourcePath := "/kv_test"
 	newSchedule, err := scheduleClient.UpdateBackupSchedule(

internal/server/services/backup_schedule/backup_schedule_service.go

@@ -2,8 +2,10 @@ package backup_schedule
 
 import (
 	"context"
+	"fmt"
 	"github.com/jonboulle/clockwork"
 	"github.com/ydb-platform/ydb-go-sdk/v3/table"
+	"google.golang.org/protobuf/types/known/durationpb"
 	"strconv"
 	"time"
 	"ydbcp/internal/auth"
@@ -133,6 +135,7 @@ func (s *BackupScheduleService) CreateBackupSchedule(
 		s.IncApiCallsCounter(methodName, codes.FailedPrecondition)
 		return nil, status.Error(codes.FailedPrecondition, "recovery point objective should be greater than 0")
 	}
+
 	var scheduleName *string
 	if len(request.ScheduleName) > 0 {
 		scheduleName = &request.ScheduleName
@@ -154,6 +157,14 @@ func (s *BackupScheduleService) CreateBackupSchedule(
 		ScheduleSettings: request.ScheduleSettings,
 	}
 
+	if schedule.ScheduleSettings.RecoveryPointObjective == nil {
+		duration, err := schedule.GetCronDuration()
+		if err != nil {
+			return nil, status.Error(codes.Internal, fmt.Sprintf("failed to get cron duration: %v", err))
+		}
+		schedule.ScheduleSettings.RecoveryPointObjective = durationpb.New(duration)
+	}
+
 	_, err = backup_operations.OpenConnAndValidateSourcePaths(ctx, backup_operations.FromBackupSchedule(&schedule), s.clientConn)
 	if err != nil {
 		return nil, err