diff --git a/modules/core/core-scheduler/src/main/java/com/enonic/xp/impl/scheduler/distributed/RescheduleTask.java b/modules/core/core-scheduler/src/main/java/com/enonic/xp/impl/scheduler/distributed/RescheduleTask.java
index 9a665bcf0a6..a4bcd1ff8e1 100644
--- a/modules/core/core-scheduler/src/main/java/com/enonic/xp/impl/scheduler/distributed/RescheduleTask.java
+++ b/modules/core/core-scheduler/src/main/java/com/enonic/xp/impl/scheduler/distributed/RescheduleTask.java
@@ -85,7 +85,10 @@ private static void scheduleOneTimeJobs( final Map<ScheduledJobName, ScheduledJo
     private static void scheduleCronJobs( final Map<ScheduledJobName, ScheduledJob> jobs, final Instant now,
                                           final Predicate<ScheduledJob> filterAlreadyScheduled )
     {
-        jobs.values().stream().filter( ScheduledJob::isEnabled ).filter( filterAlreadyScheduled )
+        jobs.values()
+            .stream()
+            .filter( ScheduledJob::isEnabled )
+            .filter( filterAlreadyScheduled )
             .filter( job -> ScheduleCalendarType.CRON.equals( job.getCalendar().getType() ) )
             .forEach( job -> {
                 final Instant actualLastRun = job.getLastRun();
@@ -211,6 +214,7 @@ private void retryFailedJobs( final List<JobToRun> failedJobs )
             if ( entity.attempts < 10 )
             {
                 QUEUE.offer( new JobToRun( entity.name, entity.timeToRun, entity.attempts + 1 ) );
+                LOG.warn( "Error while running job [{}], will try to run once more", entity.name );
             }
             else
             {