diff --git a/hw12_13_14_15_calendar/internal/sheduler/app_scheduler.go b/hw12_13_14_15_calendar/internal/sheduler/app_scheduler.go
index bb27d41..166f775 100644
--- a/hw12_13_14_15_calendar/internal/sheduler/app_scheduler.go
+++ b/hw12_13_14_15_calendar/internal/sheduler/app_scheduler.go
@@ -36,7 +36,7 @@ func New(conf Config) Scheduler {
 }
 
 func (s *Scheduler) Start(ctx context.Context) error {
-	fetcher := riseOnTick(ctx, s.Logger, func() interface{} { return worker(ctx, s.CalendarAPI, s.Rabbit) }, 1*time.Minute)
+	fetcher := riseOnTick(ctx, s.Logger, func() interface{} { return worker(ctx, s.CalendarAPI, s.Rabbit, s.Logger) }, 1*time.Minute)
 	go func() {
 		for {
 			select {
diff --git a/hw12_13_14_15_calendar/internal/sheduler/scheduler.go b/hw12_13_14_15_calendar/internal/sheduler/scheduler.go
index 6e99db8..8b309ee 100644
--- a/hw12_13_14_15_calendar/internal/sheduler/scheduler.go
+++ b/hw12_13_14_15_calendar/internal/sheduler/scheduler.go
@@ -37,7 +37,7 @@ func riseOnTick(ctx context.Context, log logger.Interface, fn func() interface{}
 	return valueStream
 }
 
-func worker(ctx context.Context, calendarAPI config.Server, rb *rabbit.Rabbit) error {
+func worker(ctx context.Context, calendarAPI config.Server, rb *rabbit.Rabbit, log logger.Interface) error {
 	cli, err := private.NewClient(calendarAPI.Address, calendarAPI.Port)
 	if err != nil {
 		return err
@@ -56,5 +56,10 @@ func worker(ctx context.Context, calendarAPI config.Server, rb *rabbit.Rabbit) e
 			return err
 		}
 	}
+	resp2, err := cli.PurgeOldEvents(ctx, &private.PurgeReq{OlderThenDays: 365})
+	if err != nil {
+		return err
+	}
+	log.Infof("Scheduler successfully purges %s events from storage", resp2.Qty)
 	return nil
 }