From bb137f4a20ce43aa3342d3db9b81626d78f00e10 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Wed, 12 Aug 2015 16:18:01 +0200
Subject: [PATCH] fixed #219
---
src/main/java/teetime/framework/AbstractRunnableStage.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/src/main/java/teetime/framework/AbstractRunnableStage.java b/src/main/java/teetime/framework/AbstractRunnableStage.java
index 6a602321..1a0449f9 100644
--- a/src/main/java/teetime/framework/AbstractRunnableStage.java
+++ b/src/main/java/teetime/framework/AbstractRunnableStage.java
@@ -84,7 +84,7 @@ abstract class AbstractRunnableStage implements Runnable {
protected abstract void afterStageExecution();
static AbstractRunnableStage create(final Stage stage) {
- if (stage.getTerminationStrategy() == TerminationStrategy.BY_SIGNAL) {
+ if (stage.getInputPorts().size() > 0) {
return new RunnableConsumerStage(stage);
} else {
return new RunnableProducerStage(stage);
--
GitLab