Switch off retry in Cassandra until we can differentiate retryable errors

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)
 

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)
 

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)