CORE-18382 Base Flow Engine fiber timeout on flow config value

corda · May 7, 2024 · 140e39d · 140e39d
1 parent 4723294
commit 140e39d
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/data/config-schema/src/main/java/net/corda/schema/configuration/FlowConfig.java b/data/config-schema/src/main/java/net/corda/schema/configuration/FlowConfig.java
@@ -16,4 +16,5 @@ private FlowConfig() {
  public static final String PROCESSING_MAX_FLOW_SLEEP_DURATION = "processing.maxFlowSleepDuration";
  public static final String PROCESSING_FLOW_MAPPER_CLEANUP_TIME = "processing.cleanupTime";
  public static final String PROCESSING_MAX_IDLE_TIME = "processing.maxIdleTime";
+ public static final String PROCESSING_FLOW_FIBER_TIMEOUT = "processing.fiberTimeout";
 }
diff --git a/.../config-schema/src/main/resources/net/corda/schema/configuration/flow/1.0/corda.flow.json b/.../config-schema/src/main/resources/net/corda/schema/configuration/flow/1.0/corda.flow.json
@@ -53,6 +53,13 @@
  "maximum": 2147483647,
  "default": 600000
  },
+ "fiberTimeout": {
+ "description": "The length of time in milliseconds before fiber times out. This value must be lower than subscription.processorTimeout.",
+ "type": "integer",
+ "minimum": 1000,
+ "maximum": 2147483647,
+ "default": 11250
+ },
  "poolSize": {
  "description": "The size of the flow event processing pool size.",
  "type": "integer",