return (Set<T>) list.stream().collect(Collectors.toSet());
}
+ /**
+ * Subclasses should override this method. See DRYD-878
+ */
@Override
public void run(BatchCommon batchCommon) {
String errMsg = String.format("%s class does not support run(BatchCommon batchCommon) method.", getClass().getName());
}
}
- batchInstance.run(batchCommon);
+ try {
+ batchInstance.run(batchCommon);
+ } catch (UnsupportedOperationException t) {
+ // Support for run() will be deprecated in a future release. See DRYD-878
+ logger.debug(t.getMessage());
+ batchInstance.run();
+ }
+
int status = batchInstance.getCompletionStatus();
if (status == Invocable.STATUS_ERROR) {
InvocationError error = batchInstance.getErrorInfo();