diff --git a/cameleer3-server-app/src/main/java/com/cameleer3/server/app/storage/PostgresExecutionStore.java b/cameleer3-server-app/src/main/java/com/cameleer3/server/app/storage/PostgresExecutionStore.java
index c1e1c8a0..9d0263de 100644
--- a/cameleer3-server-app/src/main/java/com/cameleer3/server/app/storage/PostgresExecutionStore.java
+++ b/cameleer3-server-app/src/main/java/com/cameleer3/server/app/storage/PostgresExecutionStore.java
@@ -206,7 +206,8 @@ public class PostgresExecutionStore implements ExecutionStore {
                     rs.getString("error_type"), rs.getString("error_category"),
                     rs.getString("root_cause_type"), rs.getString("root_cause_message"),
                     rs.getString("error_handler_type"), rs.getString("circuit_breaker_state"),
-                    rs.getObject("fallback_triggered") != null ? rs.getBoolean("fallback_triggered") : null);
+                    rs.getObject("fallback_triggered") != null ? rs.getBoolean("fallback_triggered") : null,
+                    null, null, null, null, null, null);
 
     private static Instant toInstant(ResultSet rs, String column) throws SQLException {
         Timestamp ts = rs.getTimestamp(column);
diff --git a/cameleer3-server-app/src/test/java/com/cameleer3/server/app/storage/PostgresExecutionStoreIT.java b/cameleer3-server-app/src/test/java/com/cameleer3/server/app/storage/PostgresExecutionStoreIT.java
index b45b89b7..affa0c29 100644
--- a/cameleer3-server-app/src/test/java/com/cameleer3/server/app/storage/PostgresExecutionStoreIT.java
+++ b/cameleer3-server-app/src/test/java/com/cameleer3/server/app/storage/PostgresExecutionStoreIT.java
@@ -77,13 +77,15 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
                         now, now.plusMillis(10), 10L, null, null,
                         "input body", "output body", null, null, null,
                         null, null, null, null, null,
-                        null, null, null, null, null, null, null, null),
+                        null, null, null, null, null, null, null, null,
+                        null, null, null, null, null, null),
                 new ProcessorRecord("exec-proc", "proc-2", "to",
                         "app-1", "route-a", 1, "proc-1", "COMPLETED",
                         now.plusMillis(10), now.plusMillis(30), 20L, null, null,
                         null, null, null, null, null,
                         null, null, null, null, null,
-                        null, null, null, null, null, null, null, null)
+                        null, null, null, null, null, null, null, null,
+                        null, null, null, null, null, null)
         );
         executionStore.upsertProcessors("exec-proc", now, "app-1", "route-a", processors);
 
diff --git a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java
index ed3a7d17..041b3dcd 100644
--- a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java
+++ b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/ingestion/IngestionService.java
@@ -159,7 +159,8 @@ public class IngestionService {
                     p.getErrorType(), p.getErrorCategory(),
                     p.getRootCauseType(), p.getRootCauseMessage(),
                     p.getErrorHandlerType(), p.getCircuitBreakerState(),
-                    p.getFallbackTriggered()
+                    p.getFallbackTriggered(),
+                    null, null, null, null, null, null
             ));
         }
         return flat;
diff --git a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/storage/ExecutionStore.java b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/storage/ExecutionStore.java
index dcaf4858..0a1b64bc 100644
--- a/cameleer3-server-core/src/main/java/com/cameleer3/server/core/storage/ExecutionStore.java
+++ b/cameleer3-server-core/src/main/java/com/cameleer3/server/core/storage/ExecutionStore.java
@@ -49,6 +49,17 @@ public interface ExecutionStore {
             String errorType, String errorCategory,
             String rootCauseType, String rootCauseMessage,
             String errorHandlerType, String circuitBreakerState,
-            Boolean fallbackTriggered
+            Boolean fallbackTriggered,
+            // New fields for ClickHouse seq-based model
+            Integer seq,
+            Integer parentSeq,
+            Integer iteration,
+            Integer iterationSize,
+            Boolean filterMatched,
+            Boolean duplicateMessage
     ) {}
+
+    default Optional<ProcessorRecord> findProcessorBySeq(String executionId, int seq) {
+        return Optional.empty();
+    }
 }
diff --git a/cameleer3-server-core/src/test/java/com/cameleer3/server/core/detail/TreeReconstructionTest.java b/cameleer3-server-core/src/test/java/com/cameleer3/server/core/detail/TreeReconstructionTest.java
index a7480d73..2f3ecd66 100644
--- a/cameleer3-server-core/src/test/java/com/cameleer3/server/core/detail/TreeReconstructionTest.java
+++ b/cameleer3-server-core/src/test/java/com/cameleer3/server/core/detail/TreeReconstructionTest.java
@@ -29,7 +29,8 @@ class TreeReconstructionTest {
                 status, NOW, NOW, 10L,
                 null, null, null, null, null, null, null,
                 null, null, null, null, null,
-                null, null, null, null, null, null, null, null
+                null, null, null, null, null, null, null, null,
+                null, null, null, null, null, null
         );
     }