Revision 44037
Added by Claudio Atzori about 8 years ago
| modules/dnet-deduplication/trunk/src/main/java/eu/dnetlib/msro/workflows/dedup/MinDistSearchHadoopJobNode.java | ||
|---|---|---|
| 112 | 112 |
case DATALOAD: |
| 113 | 113 |
token.getFullEnv().setAttribute(StatusParam, STATUS.DEPTH_N.toString()); |
| 114 | 114 |
token.getFullEnv().setAttribute(DepthParam, "0"); |
| 115 |
engine.complete(token, "depth_n");
|
|
| 115 |
complete("depth_n");
|
|
| 116 | 116 |
break; |
| 117 | 117 |
case DEPTH_N: |
| 118 | 118 |
|
| ... | ... | |
| 125 | 125 |
token.getFullEnv().removeAttribute(StatusParam); |
| 126 | 126 |
token.getFullEnv().removeAttribute(DepthParam); |
| 127 | 127 |
log.info(String.format("done iteration %s:%s", UpdateCounterParam, 0));
|
| 128 |
engine.complete(token, Arc.DEFAULT_ARC);
|
|
| 128 |
complete(Arc.DEFAULT_ARC);
|
|
| 129 | 129 |
} else {
|
| 130 | 130 |
log.info(String.format("continue with next iteration %s:%s", UpdateCounterParam, counter));
|
| 131 |
engine.complete(token, "depth_n");
|
|
| 131 |
complete("depth_n");
|
|
| 132 | 132 |
} |
| 133 | 133 |
|
| 134 | 134 |
break; |
| 135 | 135 |
} |
| 136 | 136 |
} |
| 137 |
|
|
| 138 |
private void complete(final String arc) {
|
|
| 139 |
engine.complete(token, arc); |
|
| 140 |
engine.executeQueuedArcTokens(token.getProcess()); |
|
| 141 |
} |
|
| 137 | 142 |
}; |
| 138 | 143 |
} |
| 139 | 144 |
|
Also available in: Unified diff
trying to solve sarasvati misteries of workflows that doesn't advance to named arcs