Skip to content

Commit 25321c4

Browse files
committed
upd
1 parent ca9cd58 commit 25321c4

File tree

2 files changed

+4
-1
lines changed
  • extensions-api/src/main/scala/pl/touk/nussknacker/engine/api/deployment

2 files changed

+4
-1
lines changed

engine/flink/kafka-components-utils/src/main/scala/pl/touk/nussknacker/engine/kafka/source/flink/FlinkKafkaSource.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ class FlinkKafkaSource[T](
105105
hintText = None
106106
),
107107
),
108-
ScenarioActionName("REDEPLOY") -> Map(
108+
ScenarioActionName.Redeploy -> Map(
109109
OFFSET_RESET_STRATEGY_PARAM_NAME -> ParameterConfig(
110110
defaultValue = Some(OffsetResetStrategy.None.toString),
111111
editor = Some(

extensions-api/src/main/scala/pl/touk/nussknacker/engine/api/deployment/ProcessAction.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,9 @@ object ScenarioActionName {
9292
// In the meantime, there are methods serialize and deserialize, which operate on name RUN_OFF_SCHEDULE instead.
9393
val RunOffSchedule: ScenarioActionName = ScenarioActionName("run now")
9494

95+
// For now redeploy is used to handle different UI behaviour when deploy and redeploy actions must have different sets of parameters.
96+
val Redeploy: ScenarioActionName = ScenarioActionName("REDEPLOY")
97+
9598
val DefaultActions: List[ScenarioActionName] = Nil
9699

97100
val ScenarioStatusActions: Set[ScenarioActionName] = Set(Cancel, Deploy)

0 commit comments

Comments
 (0)