Function Request: putInstance

[beilCrxmarkets]

If SchedulerClient.reschedule() is called with a TaskInstance that does not yet exist, an exception is thrown. You must therefore always check whether there is already a scheduled TaskInstance before you can call reschedule. We would therefore be pleased to have a putInstance method that automatically schedules a TaskInstance if there is none to reschedule. This is particularly convenient for dynamic recurring tasks, as these first have to be initialized.

    void putInstance(TaskInstance<Void> taskInstance, Instant executionTime) {
        var optionalExecutionObject = schedulerClient.getScheduledExecutions()
                .stream()
                .filter(e -> e.getTaskInstance().getId().equals(taskInstance.getId()))
                .findFirst();
        if (optionalExecutionObject.isPresent()) {
            schedulerClient.reschedule(taskInstance, executionTime);
        }
        else {
            schedulerClient.scheduleIfNotExists(taskInstance, executionTime);
        }
    }