2465 - update test, dispatcher don't throw exceptions but they are handled through ExecutionErrorEventListener

Author: matijapetanjek

server/libs/modules/task-dispatchers/each/src/test/java/com/bytechef/task/dispatcher/each/EachTaskDispatcherTest.java

@@ -29,6 +29,7 @@
 import com.bytechef.atlas.configuration.domain.Task;
 import com.bytechef.atlas.configuration.domain.WorkflowTask;
 import com.bytechef.atlas.coordinator.event.TaskExecutionCompleteEvent;
+import com.bytechef.atlas.coordinator.event.TaskExecutionErrorEvent;
 import com.bytechef.atlas.coordinator.task.dispatcher.TaskDispatcher;
 import com.bytechef.atlas.execution.domain.Context;
 import com.bytechef.atlas.execution.domain.TaskExecution;
@@ -46,7 +47,6 @@
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
-import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.jackson.JsonComponentModule;
 import org.springframework.context.ApplicationEventPublisher;
@@ -72,16 +72,16 @@ public class EachTaskDispatcherTest {
     }
 
     @Test
-    public void testDispatch1() {
-        Assertions.assertThrows(NullPointerException.class, () -> {
-            EachTaskDispatcher dispatcher = new EachTaskDispatcher(
-                contextService, counterService, SpelEvaluator.create(), eventPublisher, taskDispatcher,
-                taskExecutionService, taskFileStorage);
-
-            dispatcher.dispatch(TaskExecution.builder()
-                .workflowTask(new WorkflowTask(Map.of(WorkflowConstants.NAME, "name", WorkflowConstants.TYPE, "type")))
-                .build());
-        });
+    public void testEachTaskDispatcherWhenMissingRequiredParameter() {
+
+        EachTaskDispatcher dispatcher = new EachTaskDispatcher(
+            contextService, counterService, SpelEvaluator.create(), eventPublisher, taskDispatcher,
+            taskExecutionService, taskFileStorage);
+
+        dispatcher.dispatch(TaskExecution.builder()
+            .workflowTask(new WorkflowTask(Map.of(WorkflowConstants.NAME, "name", WorkflowConstants.TYPE, "type")))
+            .build());
+        verify(eventPublisher, times(1)).publishEvent(any(TaskExecutionErrorEvent.class));
     }
 
     @Test