Process task in batch if a batch config is provided, even if no batch…

… method is provided

infinitic-task-executor/src/main/kotlin/io/infinitic/tasks/executor/TaskExecutor.kt

@@ -108,9 +108,17 @@ class TaskExecutor(
       executeTasksMap.map { (serviceNameAndMethodName, executeTasks) ->
         when (serviceNameAndMethodName.first.isWorkflowTask()) {
           // for workflow tasks, we run them in parallel
-          true -> executeTasks.map { async { it.process() } }
+          true -> executeTasks.forEach { launch { it.process() } }
           // for services, we use the batched method
-          false -> async { executeTasks.process() }
+          false -> {
+            val (_, serviceMethod) = executeTasks.first().getInstanceAndMethod()
+            when (serviceMethod.getBatchMethod()) {
+              // there is no batch method, we just proceed with the task one by one
+              null -> executeTasks.forEach { launch { it.process() } }
+              // process using the batch method.
+              else -> launch { executeTasks.process() }
+            }
+          }
         }
       }
     }

infinitic-worker/src/main/kotlin/io/infinitic/workers/InfiniticWorker.kt

@@ -451,14 +451,21 @@ class InfiniticWorker(
         }
       }
 
+      val batchProcessorConfig = config.batch?.normalized(
+          "taskExecutor:" + config.serviceName,
+          config.concurrency,
+      )
+
       consumerFactory.startAsync(
           subscription = MainSubscription(ServiceExecutorTopic),
           entity = config.serviceName,
           batchReceivingConfig = config.batch,
           concurrency = config.concurrency,
           processor = processor,
           beforeDlq = beforeDlq,
-          batchProcessorConfig = { msg -> taskExecutor.getBatchConfig(msg) },
+          batchProcessorConfig = { msg ->
+            taskExecutor.getBatchConfig(msg) ?: batchProcessorConfig
+          },
           batchProcessor = batchProcessor,
       )
     }