feat(core): replace new ArrayList by Collections.emptyList()

kestra-io · Feb 28, 2025 · 2992172 · 2992172
1 parent 0d637c5
commit 2992172
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/core/src/main/java/io/kestra/core/models/flows/Flow.java b/core/src/main/java/io/kestra/core/models/flows/Flow.java
@@ -204,9 +204,9 @@ public Stream<String> allTypes() {
 
     public Stream<Task> allTasks() {
         return Stream.of(
-                this.tasks != null ? this.tasks : new ArrayList<Task>(),
-                this.errors != null ? this.errors : new ArrayList<Task>(),
-                this._finally != null ? this._finally : new ArrayList<Task>(),
+                this.tasks != null ? this.tasks : Collections.<Task>emptyList(),
+                this.errors != null ? this.errors : Collections.<Task>emptyList(),
+                this._finally != null ? this._finally : Collections.<Task>emptyList(),
                 this.listenersTasks()
             )
             .flatMap(Collection::stream);
@@ -331,7 +331,7 @@ private static Object recursiveUpdate(Object object, Task previous, Task newValu
 
     private List<Task> listenersTasks() {
         if (this.getListeners() == null) {
-            return new ArrayList<>();
+            return Collections.emptyList();
         }
 
         return this.getListeners()

diff --git a/jdbc-mysql/src/main/java/io/kestra/runner/mysql/MysqlQueue.java b/jdbc-mysql/src/main/java/io/kestra/runner/mysql/MysqlQueue.java
@@ -72,7 +72,7 @@ protected void updateGroupOffsets(DSLContext ctx, String consumerGroup, String q
                 DSL.field("CONCAT_WS(',', consumers, ?)", String.class, queueType)
             )
             .set(AbstractJdbcRepository.field("updated"), LocalDateTime.now())
-            .where(AbstractJdbcRepository.field("offset").in(offsets.toArray(Integer[]::new)));
+            .where(AbstractJdbcRepository.field("offset").in(offsets));
 
         if (consumerGroup != null) {
             update = update.and(AbstractJdbcRepository.field("consumer_group").eq(consumerGroup));