fix: add missing isReplay parameter to test constructors
The ExecutionDocument and ExecutionRecord records gained an isReplay field but the integration tests were not updated, breaking CI. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
@@ -36,7 +36,7 @@ class OpenSearchIndexIT extends AbstractPostgresIT {
|
|||||||
"OrderNotFoundException: order-12345 not found", null,
|
"OrderNotFoundException: order-12345 not found", null,
|
||||||
List.of(new ProcessorDoc("proc-1", "log", "COMPLETED",
|
List.of(new ProcessorDoc("proc-1", "log", "COMPLETED",
|
||||||
null, null, "request body with customer-99", null, null, null, null)),
|
null, null, "request body with customer-99", null, null, null, null)),
|
||||||
null, false);
|
null, false, false);
|
||||||
|
|
||||||
searchIndex.index(doc);
|
searchIndex.index(doc);
|
||||||
refreshOpenSearchIndices();
|
refreshOpenSearchIndices();
|
||||||
@@ -62,7 +62,7 @@ class OpenSearchIndexIT extends AbstractPostgresIT {
|
|||||||
now, now.plusMillis(50), 50L, null, null,
|
now, now.plusMillis(50), 50L, null, null,
|
||||||
List.of(new ProcessorDoc("proc-1", "bean", "COMPLETED",
|
List.of(new ProcessorDoc("proc-1", "bean", "COMPLETED",
|
||||||
null, null, "UniquePayloadIdentifier12345", null, null, null, null)),
|
null, null, "UniquePayloadIdentifier12345", null, null, null, null)),
|
||||||
null, false);
|
null, false, false);
|
||||||
|
|
||||||
searchIndex.index(doc);
|
searchIndex.index(doc);
|
||||||
refreshOpenSearchIndices();
|
refreshOpenSearchIndices();
|
||||||
|
|||||||
@@ -27,7 +27,7 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
|
|||||||
now, now.plusMillis(100), 100L,
|
now, now.plusMillis(100), 100L,
|
||||||
null, null, null,
|
null, null, null,
|
||||||
"REGULAR", null, null, null, null, null,
|
"REGULAR", null, null, null, null, null,
|
||||||
null, null, null, null, null, null, null, false);
|
null, null, null, null, null, null, null, false, false);
|
||||||
|
|
||||||
executionStore.upsert(record);
|
executionStore.upsert(record);
|
||||||
Optional<ExecutionRecord> found = executionStore.findById("exec-1");
|
Optional<ExecutionRecord> found = executionStore.findById("exec-1");
|
||||||
@@ -45,12 +45,12 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
|
|||||||
"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, null,
|
null, null, null, null, null, null,
|
||||||
null, null, null, null, null, null, null, false);
|
null, null, null, null, null, null, null, false, false);
|
||||||
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, null,
|
"COMPLETE", null, null, null, null, null,
|
||||||
null, null, null, null, null, null, null, false);
|
null, null, null, null, null, null, null, false, false);
|
||||||
|
|
||||||
executionStore.upsert(first);
|
executionStore.upsert(first);
|
||||||
executionStore.upsert(second);
|
executionStore.upsert(second);
|
||||||
@@ -68,7 +68,7 @@ class PostgresExecutionStoreIT extends AbstractPostgresIT {
|
|||||||
"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, null,
|
"COMPLETE", null, null, null, null, null,
|
||||||
null, null, null, null, null, null, null, false);
|
null, null, null, null, null, null, null, false, false);
|
||||||
executionStore.upsert(exec);
|
executionStore.upsert(exec);
|
||||||
|
|
||||||
List<ProcessorRecord> processors = List.of(
|
List<ProcessorRecord> processors = List.of(
|
||||||
|
|||||||
@@ -61,6 +61,6 @@ class PostgresStatsStoreIT extends AbstractPostgresIT {
|
|||||||
startTime, startTime.plusMillis(durationMs), durationMs,
|
startTime, startTime.plusMillis(durationMs), durationMs,
|
||||||
status.equals("FAILED") ? "error" : null, null, null,
|
status.equals("FAILED") ? "error" : null, null, null,
|
||||||
null, null, null, null, null, null,
|
null, null, null, null, null, null,
|
||||||
null, null, null, null, null, null, null, false));
|
null, null, null, null, null, null, null, false, false));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user