Method Run

common/sync/task/sync.go:175–204

Run runs the sync with panic recovery

(ctx context.Context, dryRun bool, force bool)

// Run runs the sync with panic recovery
func (s *Sync) Run(ctx context.Context, dryRun bool, force bool) (model.Stater, error) {
	var err error
	defer func() {
		if e := recover(); e != nil {
			fmt.Println("stacktrace from panic: \n" + string(debug.Stack()))
			if er, ok := e.(error); ok {
				err = er
				if s.statuses != nil {
					s.statuses <- model.NewProcessingStatus(err.Error()).SetError(err).SetProgress(1)
				}
				if s.runDone != nil {
					s.runDone <- 0
				}
			}
		}
	}()

	stater, err := s.run(ctx, dryRun, force)
	if err != nil && s.statuses != nil {
		s.statuses <- model.NewProcessingStatus(err.Error()).SetError(err).SetProgress(1)
		if s.runDone != nil {
			if stater != nil {
				s.runDone <- stater
			} else {
				s.runDone <- 0
			}
		}
	}
	return stater, err
}

func (s *Sync) ReApplyPatch(ctx context.Context, patch merger.Patch) {
	patch.SkipFilterToTarget(false)