fix: update ExecutionRecord constructor calls in tests for new fields
This commit is contained in:
@@ -25,7 +25,8 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
|
|||||||
"exec-1", "route-a", "agent-1", "app-1",
|
"exec-1", "route-a", "agent-1", "app-1",
|
||||||
"COMPLETED", "corr-1", "exchange-1",
|
"COMPLETED", "corr-1", "exchange-1",
|
||||||
now, now.plusMillis(100), 100L,
|
now, now.plusMillis(100), 100L,
|
||||||
null, null, null);
|
null, null, null,
|
||||||
|
"REGULAR", null, null, null, null);
|
||||||
|
|
||||||
executionStore.upsert(record);
|
executionStore.upsert(record);
|
||||||
Optional<ExecutionRecord> found = executionStore.findById("exec-1");
|
Optional<ExecutionRecord> found = executionStore.findById("exec-1");
|
||||||
@@ -33,6 +34,7 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
|
|||||||
assertTrue(found.isPresent());
|
assertTrue(found.isPresent());
|
||||||
assertEquals("exec-1", found.get().executionId());
|
assertEquals("exec-1", found.get().executionId());
|
||||||
assertEquals("COMPLETED", found.get().status());
|
assertEquals("COMPLETED", found.get().status());
|
||||||
|
assertEquals("REGULAR", found.get().engineLevel());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
@@ -40,10 +42,12 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
|
|||||||
Instant now = Instant.now();
|
Instant now = Instant.now();
|
||||||
ExecutionRecord first = new ExecutionRecord(
|
ExecutionRecord first = new ExecutionRecord(
|
||||||
"exec-dup", "route-a", "agent-1", "app-1",
|
"exec-dup", "route-a", "agent-1", "app-1",
|
||||||
"RUNNING", null, null, now, null, null, null, null, null);
|
"RUNNING", null, null, now, null, null, null, null, null,
|
||||||
|
null, null, null, null, null);
|
||||||
ExecutionRecord second = new ExecutionRecord(
|
ExecutionRecord second = new ExecutionRecord(
|
||||||
"exec-dup", "route-a", "agent-1", "app-1",
|
"exec-dup", "route-a", "agent-1", "app-1",
|
||||||
"COMPLETED", null, null, now, now.plusMillis(200), 200L, null, null, null);
|
"COMPLETED", null, null, now, now.plusMillis(200), 200L, null, null, null,
|
||||||
|
"COMPLETE", null, null, null, null);
|
||||||
|
|
||||||
executionStore.upsert(first);
|
executionStore.upsert(first);
|
||||||
executionStore.upsert(second);
|
executionStore.upsert(second);
|
||||||
@@ -59,7 +63,8 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
|
|||||||
Instant now = Instant.now();
|
Instant now = Instant.now();
|
||||||
ExecutionRecord exec = new ExecutionRecord(
|
ExecutionRecord exec = new ExecutionRecord(
|
||||||
"exec-proc", "route-a", "agent-1", "app-1",
|
"exec-proc", "route-a", "agent-1", "app-1",
|
||||||
"COMPLETED", null, null, now, now.plusMillis(50), 50L, null, null, null);
|
"COMPLETED", null, null, now, now.plusMillis(50), 50L, null, null, null,
|
||||||
|
"COMPLETE", null, null, null, null);
|
||||||
executionStore.upsert(exec);
|
executionStore.upsert(exec);
|
||||||
|
|
||||||
List<ProcessorRecord> processors = List.of(
|
List<ProcessorRecord> processors = List.of(
|
||||||
|
|||||||
Reference in New Issue
Block a user