Wrong type for the analysis_state_journal.error

OHDSI · Jan 10, 2025 · 98bd997 · 98bd997
1 parent c91dca6
commit 98bd997
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 1 deletion.
diff --git a/datanode/src/main/java/com/odysseusinc/arachne/datanode/service/AnalysisService.java b/datanode/src/main/java/com/odysseusinc/arachne/datanode/service/AnalysisService.java
@@ -220,7 +220,7 @@ public List<Long> getIncompleteIds() {
 			Join<Analysis, AnalysisStateEntry> state = root.join(Analysis_.currentState, JoinType.LEFT);
 			javax.persistence.criteria.Path<String> stage = state.get(AnalysisStateEntry_.stage);
 			return q.where(
-					cb.isNull(root.get(Analysis_.error)),
+					cb.isNull(state.get(AnalysisStateEntry_.error)),
 					cb.or(stage.isNull(), stage.in(Stage.EXECUTE, Stage.INITIALIZE, Stage.ABORT))
 			);
 		}).getResultStream().map(Analysis::getId).collect(Collectors.toList());

diff --git a/datanode/src/main/resources/db/migration/V20241210000005__change_error_to_varchar.sql b/datanode/src/main/resources/db/migration/V20241210000005__change_error_to_varchar.sql
@@ -0,0 +1,2 @@
+ALTER TABLE analysis_state_journal
+    ALTER COLUMN error TYPE VARCHAR;
diff --git a/datanode/src/main/resources/db/migration/V20241210000006__update_stage_and_error.sql b/datanode/src/main/resources/db/migration/V20241210000006__update_stage_and_error.sql
@@ -0,0 +1,4 @@
+UPDATE analysis_state_journal SET
+                                  stage = analyses.stage,
+                                  error = analyses.error
+FROM analyses WHERE analyses.current_state_id = analysis_state_journal.id;
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,2 @@
		ALTER TABLE analysis_state_journal
		ALTER COLUMN error TYPE VARCHAR;