1057 Improve Map task dispatcher variable properties and output handling

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: ivicac

server/libs/modules/task-dispatchers/map/src/main/java/com/bytechef/task/dispatcher/map/MapTaskDispatcherDefinitionFactory.java

@@ -33,14 +33,15 @@
 import com.bytechef.definition.BaseOutputDefinition.OutputResponse;
 import com.bytechef.platform.util.SchemaUtils;
 import com.bytechef.platform.workflow.task.dispatcher.TaskDispatcherDefinitionFactory;
-import com.bytechef.platform.workflow.task.dispatcher.definition.Property.ObjectProperty;
 import com.bytechef.platform.workflow.task.dispatcher.definition.PropertyFactory;
 import com.bytechef.platform.workflow.task.dispatcher.definition.TaskDispatcherDefinition;
 import com.bytechef.platform.workflow.task.dispatcher.definition.TaskDispatcherDsl.ModifiableValueProperty;
 import com.bytechef.platform.workflow.task.dispatcher.map.MapDataSource;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Optional;
+import org.slf4j.Logger;
 import org.springframework.stereotype.Component;
 import tools.jackson.core.type.TypeReference;
 
@@ -50,6 +51,8 @@
 @Component
 public class MapTaskDispatcherDefinitionFactory implements TaskDispatcherDefinitionFactory {
 
+    private static final Logger logger = org.slf4j.LoggerFactory.getLogger(MapTaskDispatcherDefinitionFactory.class);
+
     private final TaskDispatcherDefinition taskDispatcherDefinition;
 
     public MapTaskDispatcherDefinitionFactory(Optional<MapDataSource> mapDataSource) {
@@ -79,7 +82,7 @@ protected static OutputResponse output(Map<String, ?> inputParameters, MapDataSo
         long environmentId = MapUtils.getLong(inputParameters, ENVIRONMENT_ID, 0L);
 
         List<Map<String, ?>> iterateeTasks = MapUtils.getList(
-            inputParameters, ITERATEE, new TypeReference<Map<String, ?>>() {}, List.of());
+            inputParameters, ITERATEE, new TypeReference<>() {}, List.of());
 
         if (iterateeTasks.isEmpty()) {
             return null;
@@ -101,8 +104,7 @@ protected static OutputResponse output(Map<String, ?> inputParameters, MapDataSo
             return null;
         }
 
-        ModifiableValueProperty<?, ?> lastTaskSchema =
-            (ModifiableValueProperty<?, ?>) lastTaskOutput.getOutputSchema();
+        ModifiableValueProperty<?, ?> lastTaskSchema = (ModifiableValueProperty<?, ?>) lastTaskOutput.getOutputSchema();
 
         Object lastTaskSampleOutput = lastTaskOutput.getSampleOutput();
 
@@ -114,20 +116,34 @@ protected static OutputResponse output(Map<String, ?> inputParameters, MapDataSo
     }
 
     protected static OutputResponse variableProperties(Map<String, ?> inputParameters) {
-        ObjectProperty variableProperties;
+        OutputResponse outputResponse;
+        List<?> list = List.of();
+
+        if (MapUtils.containsKey(inputParameters, ITEMS)) {
+            // TODO Remove once UI suppress executing outputs if previous nodes don't have defined output
+            try {
+                list = MapUtils.getList(inputParameters, ITEMS, List.of());
+            } catch (Exception e) {
+                if (logger.isDebugEnabled()) {
+                    logger.debug(e.getMessage());
+                }
+            }
+        }
 
-        List<?> list = MapUtils.getRequiredList(inputParameters, ITEMS);
+        boolean allNull = list.isEmpty() || list.stream()
+            .allMatch(Objects::isNull);
 
-        if (list.isEmpty()) {
-            variableProperties = object();
+        if (allNull) {
+            outputResponse = OutputResponse.of(
+                object().properties(object(ITEM), integer(INDEX)), Map.of(ITEM, Map.of(), INDEX, 0));
         } else {
-            ModifiableValueProperty<?, ?> outputSchema = (ModifiableValueProperty<?, ?>) SchemaUtils.getOutputSchema(
+            ModifiableValueProperty<?, ?> itemProperty = (ModifiableValueProperty<?, ?>) SchemaUtils.getOutputSchema(
                 ITEM, list.getFirst(), PropertyFactory.PROPERTY_FACTORY);
 
-            variableProperties = object()
-                .properties(outputSchema, integer(INDEX));
+            outputResponse = OutputResponse.of(
+                object().properties(itemProperty, integer(INDEX)), Map.of(ITEM, list.getFirst(), INDEX, 0));
         }
 
-        return OutputResponse.of(variableProperties);
+        return outputResponse;
     }
 }