Only retry transaction function in case of known transient error

transistive · transistive · commit 29960e8070b3 · 2021-07-10T23:56:04.000+02:00
diff --git a/src/Common/TransactionHelper.php b/src/Common/TransactionHelper.php
@@ -46,7 +46,7 @@ public static function retry(callable $tsxFactory, callable $tsxHandler, Transac
 
                 return $tbr;
             } catch (Neo4jException $e) {
-                if (microtime(true) > $limit) {
+                if (microtime(true) > $limit || !str_contains($e->getMessage(), '(Neo.ClientError.Cluster.NotALeader)')) {
                     throw $e;
                 }
             }

Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ public static function retry(callable $tsxFactory, callable $tsxHandler, Transac`
`46`	`46`
`47`	`47`	`return $tbr;`
`48`	`48`	`} catch (Neo4jException $e) {`
`49`		`- if (microtime(true) > $limit) {`
	`49`	`+ if (microtime(true) > $limit \|\| !str_contains($e->getMessage(), '(Neo.ClientError.Cluster.NotALeader)')) {`
`50`	`50`	`throw $e;`
`51`	`51`	`}`
`52`	`52`	`}`