Merge pull request #91 from fbiville/issue_90

Do not send negative transaction timeout values
z5labs · Feb 22, 2022 · a8ccfb6 · a8ccfb6
2 parents e7505e2 + 0006566
commit a8ccfb6
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/sessionv2.go b/sessionv2.go
@@ -540,7 +540,11 @@ func (s *SessionV2Impl) runWrite(ctx context.Context, work neo4j.TransactionWork
 	}
 
 	s.gogm.logger.Debug("running in managed write transaction")
-	_, err := s.neoSess.WriteTransaction(work, neo4j.WithTxTimeout(time.Until(s.getDeadline(ctx))))
+	duration := time.Until(s.getDeadline(ctx))
+	if duration < 0 {
+		duration = 0
+	}
+	_, err := s.neoSess.WriteTransaction(work, neo4j.WithTxTimeout(duration))
 	if err != nil {
 		return fmt.Errorf("failed to save in auto transaction, %w", err)
 	}