Skip to content

Commit 47cb871

Browse files
committed
Improve error logging for when recording source causes duplicate
1 parent 5c304db commit 47cb871

3 files changed

Lines changed: 8 additions & 3 deletions

File tree

query-engine/docs/query-engine-compose.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ services:
5050
- 16686:16686
5151

5252
query-engine:
53-
image: ghcr.io/yaytay/query-engine-design-mode:0.2.15-5-main
53+
image: ghcr.io/yaytay/query-engine-design-mode:0.2.15-6-main
5454
ports:
5555
- 2000:8080
5656
volumes:

query-engine/src/main/java/uk/co/spudsoft/query/exec/AuditorPersistenceImpl.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1188,13 +1188,18 @@ public Future<Void> recordSource(PipelineContext pipelineContext, String endpoin
11881188
ps.setClob(6, new StringReader(argsJson)); // CLOB-safe
11891189
}).onComplete(ar -> {
11901190
if (ar.failed()) {
1191-
Log.decorate(logger.atWarn(), pipelineContext).log("Faild to write record source: ", ar.cause());
1191+
Log.decorate(logger.atWarn(), pipelineContext).log("Faild to record source: ", ar.cause());
11921192
}
11931193
jdbcHelper.runSqlUpdate("recordRequestSource", SqlTemplate.RECORD_REQUEST_SOURCE.sql(), ps -> {
11941194
ps.setString(1, pipelineContext.getRequestContext().getRequestId());
11951195
ps.setString(2, JdbcHelper.limitLength(pipelineContext.getPipe(), 250));
11961196
ps.setTimestamp(3, Timestamp.from(Instant.now()), cal);
11971197
ps.setString(4, JdbcHelper.limitLength(hash, 32));
1198+
})
1199+
.onComplete(ar2 -> {
1200+
if (ar2.failed()) {
1201+
Log.decorate(logger.atWarn(), pipelineContext).log("Faild to record request source: ", ar.cause());
1202+
}
11981203
});
11991204
}).mapEmpty();
12001205
}

query-engine/src/main/java/uk/co/spudsoft/query/main/Version.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public final class Version {
3434
/**
3535
* The project version, as set in the Maven pom.xml.
3636
*/
37-
public static final String MAVEN_PROJECT_VERSION = "0.2.15-5-main";
37+
public static final String MAVEN_PROJECT_VERSION = "0.2.15-6-main";
3838

3939
private Version() {
4040
}

0 commit comments

Comments
 (0)