fixed build

Author: sterlp

core/src/main/java/org/sterl/spring/persistent_tasks/trigger/RunningTriggerContextHolder.java

@@ -38,7 +38,7 @@ public static String getCorrelationId() {
      * @return either the set correlationId or the desired one or a random build one.
      */
     public static String buildOrGetCorrelationId(String newCorrelationId) {
-        var correlationId = RunningTriggerContextHolder.getCorrelationId();
+        var correlationId = getCorrelationId();
         if (correlationId == null) correlationId = newCorrelationId;
         if (correlationId == null) correlationId = UUID.randomUUID().toString();
         return correlationId;

core/src/main/java/org/sterl/spring/persistent_tasks/trigger/model/RunTaskWithStateCommand.java

@@ -15,14 +15,14 @@
 
 public record RunTaskWithStateCommand (
         ApplicationEventPublisher eventPublisher,
-        PersistentTaskBase<Serializable> task,
+        PersistentTaskBase task,
         Optional<TransactionTemplate> trx,
         Serializable state,
         TriggerEntity trigger,
         RunningTrigger<Serializable> runningTrigger) implements HasTriggerData {
 
     public RunTaskWithStateCommand(ApplicationEventPublisher eventPublisher,
-        PersistentTaskBase<Serializable> task,
+        PersistentTaskBase task,
         Optional<TransactionTemplate> trx,
         Serializable state,
         TriggerEntity trigger) {
@@ -48,9 +48,9 @@ private Optional<TriggerEntity> runTask(EditTriggerComponent editTrigger) {
         editTrigger.triggerIsNowRunning(trigger, state);
 
         Collection<AddTriggerRequest<Serializable>> nextTriggers = null;
-        if (task instanceof ComplexPersistentTask<Serializable, Serializable> complexTask) {
+        if (task instanceof ComplexPersistentTask complexTask) {
             nextTriggers = complexTask.accept(runningTrigger);
-        } else if (task instanceof PersistentTask<Serializable> simpleTask) {
+        } else if (task instanceof PersistentTask simpleTask) {
             simpleTask.accept(state); // Direct state handling
         } else {
             throw new IllegalStateException("Unsupported task type: " + task.getClass());