Skip to content
Snippets Groups Projects
Commit 9d925c7c authored by Christian Wulf's avatar Christian Wulf
Browse files

fixed cause of test failures

parent 7b88940f
No related branches found
No related tags found
No related merge requests found
...@@ -119,7 +119,8 @@ public abstract class AbstractStage extends Stage { ...@@ -119,7 +119,8 @@ public abstract class AbstractStage extends Stage {
@Override @Override
public void validateOutputPorts(final List<InvalidPortConnection> invalidPortConnections) { public void validateOutputPorts(final List<InvalidPortConnection> invalidPortConnections) {
for (OutputPort<?> outputPort : this.getOutputPorts()) { // for (OutputPort<?> outputPort : this.getOutputPorts()) {
for (OutputPort<?> outputPort : this.outputPortList) {
final IPipe pipe = outputPort.getPipe(); final IPipe pipe = outputPort.getPipe();
if (null != pipe) { // if output port is connected with another one if (null != pipe) { // if output port is connected with another one
final Class<?> sourcePortType = outputPort.getType(); final Class<?> sourcePortType = outputPort.getType();
......
...@@ -33,13 +33,13 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -33,13 +33,13 @@ public class Analysis implements UncaughtExceptionHandler {
private final Collection<Pair<Thread, Throwable>> exceptions = new ConcurrentLinkedQueue<Pair<Thread, Throwable>>(); private final Collection<Pair<Thread, Throwable>> exceptions = new ConcurrentLinkedQueue<Pair<Thread, Throwable>>();
/** /**
* Creates a new {@link Analysis} that initially validates the port connections. * Creates a new {@link Analysis} that skips validating the port connections.
* *
* @param configuration * @param configuration
* to be used for the analysis * to be used for the analysis
*/ */
public Analysis(final AnalysisConfiguration configuration) { public Analysis(final AnalysisConfiguration configuration) {
this(configuration, true); this(configuration, false);
} }
public Analysis(final AnalysisConfiguration configuration, final boolean validationEnabled) { public Analysis(final AnalysisConfiguration configuration, final boolean validationEnabled) {
......
...@@ -24,9 +24,9 @@ public class InvalidPortConnection { ...@@ -24,9 +24,9 @@ public class InvalidPortConnection {
@Override @Override
public String toString() { public String toString() {
final String sourcePortTypeName = (this.sourcePort.getType() == null) ? null : this.sourcePort.getType().getName(); final String sourcePortTypeName = (this.sourcePort.getType() == null) ? "null" : this.sourcePort.getType().getName();
final String targetPortTypeName = (this.targetPort.getType() == null) ? null : this.targetPort.getType().getName(); final String targetPortTypeName = (this.targetPort.getType() == null) ? "null" : this.targetPort.getType().getName();
return sourcePortTypeName + " != " + targetPortTypeName; return "Source port type does not match target port type: " + sourcePortTypeName + " != " + targetPortTypeName;
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment