Skip to content

Commit 9c92c5a

Browse files
committed
upd
1 parent b9adcaa commit 9c92c5a

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

+1-1
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,7 @@ class FlinkKafkaSource[T](
107107
hintText = None
108108
),
109109
),
110-
ScenarioActionName("REDEPLOY") -> Map(
110+
ScenarioActionName.Redeploy -> Map(
111111
OFFSET_RESET_STRATEGY_PARAM_NAME -> ParameterConfig(
112112
defaultValue = Some(OffsetResetStrategy.None.toString),
113113
editor = Some(

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

+3
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)