BlockArgument arg;
            if (traceUpwardsToArgument(operands[blockArg.getArgNumber()], seen,
                                       &arg)
                    .succeeded()) {
              options.insert(arg);
            }
          }
        } else {
          op->emitOpError("Predecessor op doesn't implement BranchOpInterface");
          return failure();
        }
      }

            controller.transition(TestState.A, TestState.B, action)
        }

        then:
        1 * action.apply(_) >> { ExecutionResult r ->
            assert r.failures.empty
            ExecutionResult.succeeded()
        }
        0 * action._
        result.failures.empty
    }

    def "can transition to new state and take previous failure as input"() {
        def action = Mock(Function)

    status: statusValue
    type: typeValue
  failed: 6
  failedIndexes: failedIndexesValue
  ready: 9
  startTime: "2002-01-01T01:01:01Z"
  succeeded: 5
  terminating: 11
  uncountedTerminatedPods:
    failed:
    - failedValue
    succeeded:

			// but finalizeDelete returns a metav1.Status, so return
			// the object in the request instead.
			return obj, false, err
		}
		return nil, false, storeerr.InterpretDeleteError(err, e.qualifiedResourceFromContext(ctx), name)
	}
	_, err := e.finalizeDelete(ctx, out, true, options)
	// clients are expecting an updated object if a PUT succeeded, but

    "startTime": "2002-01-01T01:01:01Z",
    "completionTime": "2003-01-01T01:01:01Z",
    "active": 4,
    "succeeded": 5,
    "failed": 6,
    "terminating": 11,
    "completedIndexes": "completedIndexesValue",
    "failedIndexes": "failedIndexesValue",
    "uncountedTerminatedPods": {
      "succeeded": [
        "succeededValue"
      ],
      "failed": [
        "failedValue"
      ]
    },

	gvr := getGVRFromResource(toBeProcessedSVM)

	if IsConditionTrue(toBeProcessedSVM, svmv1alpha1.MigrationSucceeded) || IsConditionTrue(toBeProcessedSVM, svmv1alpha1.MigrationFailed) {
		logger.V(4).Info("Migration has already succeeded or failed previously, skipping", "svm", name)
		return nil
	}

	if len(toBeProcessedSVM.Status.ResourceVersion) != 0 {
		logger.V(4).Info("Resource version is already set", "svm", name)
		return nil
	}

    "startTime": "2002-01-01T01:01:01Z",
    "completionTime": "2003-01-01T01:01:01Z",
    "active": 4,
    "succeeded": 5,
    "failed": 6,
    "terminating": 11,
    "completedIndexes": "completedIndexesValue",
    "failedIndexes": "failedIndexesValue",
    "uncountedTerminatedPods": {
      "succeeded": [
        "succeededValue"
      ],
      "failed": [
        "failedValue"
      ]
    },

    status: statusValue
    type: typeValue
  failed: 6
  failedIndexes: failedIndexesValue
  ready: 9
  startTime: "2002-01-01T01:01:01Z"
  succeeded: 5
  terminating: 11
  uncountedTerminatedPods:
    failed:
    - failedValue
    succeeded:

      if (executed) {
        return;
      }
      executed = true;
      list = runnables;
      runnables = null; // allow GC to free listeners even if this stays around for a while.
    }
    // If we succeeded then list holds all the runnables we to execute. The pairs in the stack are
    // in the opposite order from how they were added so we need to reverse the list to fulfill our
    // contract.

        } else if (failureCollector.getFlakyScenarioSmallRegressions() != 0) {
            messageTemplate = ", flaky scenario %s regressed slightly.";
        } else {
            messageTemplate = ", scenario %s succeeded.";
        }
        return String.format(messageTemplate, performanceExperiment.getDisplayName());
    }