private static void assertScheduledFnsNotEqual(ScheduledFunction scheduledFn, ScheduledFunction scheduledFn1) {
    if (scheduledFn == scheduledFn1 && scheduledFn == null) {
      return;
    }
    assertNotEquals(scheduledFn, scheduledFn1);
  }
Test util methods for {@link OperatorSpec} classes
samza-core/src/test/java/org/apache/samza/operators/spec/OperatorSpecTestUtils.java