From 78da36398c8b4a1d62a9c2dc728dbf98e649e402 Mon Sep 17 00:00:00 2001
From: Cyber MacGeddon <cybermaggedon@gmail.com>
Date: Wed, 7 May 2025 23:10:30 +0100
Subject: [PATCH] Switch off retry in Cassandra until we can differentiate
 retryable errors

---
 trustgraph-flow/trustgraph/tables/config.py    | 7 +++++++
 trustgraph-flow/trustgraph/tables/knowledge.py | 8 ++++++++
 trustgraph-flow/trustgraph/tables/library.py   | 9 +++++++++
 3 files changed, 24 insertions(+)

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)