Improves fix for broken start connection to also keep step position index in consistent state
@@ -650,15 +650,11 @@ export class CurrentFlowService {
}
};
- const stepsToVisit = this.currentFlow.steps.filter(step => step.action !== undefined);
- if (stepsToVisit.length === 0) {
- then();
- }
-
- stepsToVisit.forEach((step, position) => {
+ this.currentFlow.steps.forEach((step, position) => {
outstanding = outstanding + 1;
switch (step.stepKind) {
case ENDPOINT:
+ if (step.action !== undefined) {
const sub = this.integrationSupportService
.fetchMetadata(
step.connection,
@@ -680,6 +676,9 @@ export class CurrentFlowService {
decrementCount();
}
);
+ } else {
+ decrementCount();
+ }
break;
case SPLIT:
case AGGREGATE:
