From f11bed119f84d0f1491833d65e80a971916e67a5 Mon Sep 17 00:00:00 2001
From: Nathaniel Bauernfeind <natebauernfeind@deephaven.io>
Date: Wed, 10 Jan 2024 12:05:46 -0700
Subject: [PATCH] Ryan's feedback rnd3

---
 .../engine/table/impl/InstrumentedTableUpdateSource.java        | 2 ++
 .../engine/testutil/testcase/RefreshingTableTestCase.java       | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/engine/table/src/main/java/io/deephaven/engine/table/impl/InstrumentedTableUpdateSource.java b/engine/table/src/main/java/io/deephaven/engine/table/impl/InstrumentedTableUpdateSource.java
index c49542644e2..40ec78383ed 100644
--- a/engine/table/src/main/java/io/deephaven/engine/table/impl/InstrumentedTableUpdateSource.java
+++ b/engine/table/src/main/java/io/deephaven/engine/table/impl/InstrumentedTableUpdateSource.java
@@ -22,6 +22,8 @@ public InstrumentedTableUpdateSource(
             final BaseTable<?> table,
             final String description) {
         super(updateSourceRegistrar, description);
+        // verify that the updateSourceRegistrar's update graph is the same as the table's update graph (if applicable)
+        updateSourceRegistrar.getUpdateGraph(table);
         tableReference = new WeakReference<>(table);
     }
 
diff --git a/engine/test-utils/src/main/java/io/deephaven/engine/testutil/testcase/RefreshingTableTestCase.java b/engine/test-utils/src/main/java/io/deephaven/engine/testutil/testcase/RefreshingTableTestCase.java
index b0e964b9e89..813cd115d5e 100644
--- a/engine/test-utils/src/main/java/io/deephaven/engine/testutil/testcase/RefreshingTableTestCase.java
+++ b/engine/test-utils/src/main/java/io/deephaven/engine/testutil/testcase/RefreshingTableTestCase.java
@@ -136,7 +136,7 @@ public <T> T allowingError(Supplier<T> function, Predicate<List<Throwable>> erro
         } finally {
             setExpectError(original);
         }
-        if (errors == null && !errorsAcceptable.test(errors)) {
+        if (errors != null && !errorsAcceptable.test(errors)) {
             TestCase.fail("Unacceptable errors: " + errors);
         }
         return retval;