diff --git a/trustgraph-flow/trustgraph/tables/config.py b/trustgraph-flow/trustgraph/tables/config.py
index 3b9c2eb9..45dfc4d9 100644
--- a/trustgraph-flow/trustgraph/tables/config.py
+++ b/trustgraph-flow/trustgraph/tables/config.py
@@ -161,6 +161,7 @@ class ConfigTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -180,6 +181,7 @@ class ConfigTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -204,6 +206,7 @@ class ConfigTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -228,6 +231,7 @@ class ConfigTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -251,6 +255,7 @@ class ConfigTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -275,6 +280,7 @@ class ConfigTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -297,6 +303,7 @@ class ConfigTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
diff --git a/trustgraph-flow/trustgraph/tables/knowledge.py b/trustgraph-flow/trustgraph/tables/knowledge.py
index 3996b5a7..36414dc4 100644
--- a/trustgraph-flow/trustgraph/tables/knowledge.py
+++ b/trustgraph-flow/trustgraph/tables/knowledge.py
@@ -232,6 +232,7 @@ class KnowledgeTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -276,6 +277,7 @@ class KnowledgeTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -320,6 +322,7 @@ class KnowledgeTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -340,6 +343,7 @@ class KnowledgeTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -370,6 +374,7 @@ class KnowledgeTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -386,6 +391,7 @@ class KnowledgeTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -406,6 +412,7 @@ class KnowledgeTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -463,6 +470,7 @@ class KnowledgeTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
diff --git a/trustgraph-flow/trustgraph/tables/library.py b/trustgraph-flow/trustgraph/tables/library.py
index 4168fd2b..c8cdb027 100644
--- a/trustgraph-flow/trustgraph/tables/library.py
+++ b/trustgraph-flow/trustgraph/tables/library.py
@@ -232,6 +232,7 @@ class LibraryTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -267,6 +268,7 @@ class LibraryTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -292,6 +294,7 @@ class LibraryTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -314,6 +317,7 @@ class LibraryTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -361,6 +365,7 @@ class LibraryTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -407,6 +412,7 @@ class LibraryTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -455,6 +461,7 @@ class LibraryTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -480,6 +487,7 @@ class LibraryTableStore:
             except Exception as e:
 
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)
 
@@ -502,6 +510,7 @@ class LibraryTableStore:
 
             except Exception as e:
                 print("Exception:", type(e))
+                raise e
                 print(f"{e}, retry...", flush=True)
                 await asyncio.sleep(1)