@@ -7,6 +7,7 @@ import com.typesafe.scalalogging.LazyLogging
7
7
import pl .touk .nussknacker .engine .api .{JobData , NodeId }
8
8
import pl .touk .nussknacker .engine .api .definition .{Parameter => ParameterDefinition }
9
9
import pl .touk .nussknacker .engine .api .parameter .ParameterName
10
+ import pl .touk .nussknacker .engine .compile .CompilationLoggerExtensions .Ops
10
11
import pl .touk .nussknacker .engine .graph .evaluatedparam .{Parameter => NodeParameter }
11
12
import pl .touk .nussknacker .engine .util .Implicits .RichTupleList
12
13
@@ -30,9 +31,8 @@ object NodeParametersAdjuster extends LazyLogging {
30
31
): Unit = {
31
32
val redundantParams = parameters.map(_.name).toSet.diff(parameterDefinitions.map(_.name).toSet)
32
33
if (redundantParams.nonEmpty) {
33
- logger.warn(
34
- s " Scenario [ ${jobData.metaData.name}] node [ $nodeId] compilation warning. " +
35
- s " Found redundant parameters: ${redundantParams.toList.map(_.value).sorted.mkString(" , " )}. They will be skipped. "
34
+ logger.compilationWarning(
35
+ s " Found redundant parameters: ${redundantParams.toList.map(_.value).sorted.mkString(" , " )}. They will be skipped. "
36
36
)
37
37
}
38
38
}
@@ -61,9 +61,8 @@ object NodeParametersAdjuster extends LazyLogging {
61
61
.sequence
62
62
.run
63
63
if (missingParameterNames.nonEmpty) {
64
- logger.warn(
65
- s " Scenario [ ${jobData.metaData.name}] node [ $nodeId] compilation warning. " +
66
- s " Found missing parameters: ${missingParameterNames.toList.map(_.value).sorted.mkString(" , " )}. " +
64
+ logger.compilationWarning(
65
+ s " Found missing parameters: ${missingParameterNames.toList.map(_.value).sorted.mkString(" , " )}. " +
67
66
s " They will be recovered based on the default value from parameters definitions. "
68
67
)
69
68
}
0 commit comments