How to execute OneTime ask if application crashes before scheduled time

[vipinvijay1986]

Hi Kagkarlsson and community,
I am creating a OneTime execution task that needs to be scheduled after 30 seconds of the current time. However, there is a possibility that the application might crash before actual execution. In such a case, the task does not get executed. And after this crash, if I create a new job at that previous job executions get completed. So how to resolve this issue?
The second question I have is, how to schedule jobs only on transaction commits.

           //Definition of async  task
            OneTimeTask<JobDetailDTO> oneTimeTask =
                    Tasks.oneTime("OneTime", JobDetailDTO.class).onFailure(new FailureHandler.MaxRetriesFailureHandler<>(3, (executionComplete, executionOperations) -> {
                        // try again in 10 second
                        logger.error("Execution has failed " + executionComplete.getExecution().consecutiveFailures
                                + " times. Trying again in a bit...");
                        executionOperations.reschedule(executionComplete, Instant.now().plusSeconds(10));
                    })).onDeadExecution(new DeadExecutionHandler<JobDetailDTO>() {

                        @Override
                        public void deadExecution(ExecutionComplete executionComplete,
                                                  ExecutionOperations<JobDetailDTO> executionOperations) {
                            logger.error("Dead execution {}", executionComplete);
                        }
                    }).execute((inst, ctx) -> {
                        logger.error("Executing async task {}", inst);
                        logger.error("Executing async task get Data {}", inst.getData());
                         
                    });
          

            final Scheduler scheduler =
                    Scheduler.create(dataSource , oneTimeTask).threads(5).registerShutdownHook().build();
            scheduler.schedule(oneTimeTask.instance(job.getId(), job), Instant.now().plusSeconds(30));