(ctx context.Context, query string, args ...any)
| 254 | if sess == nil { |
| 255 | return |
| 256 | } |
| 257 | if len(sess.postPhysical) == 0 { |
| 258 | sess.postPhysicalOrder = nil |
| 259 | return |
| 260 | } |
| 261 | for tx, state := range sess.postPhysical { |
| 262 | completed, completedAt := state.completionSnapshot() |
| 263 | if completed && !completedAt.IsZero() && now.Sub(completedAt) >= postPhysicalTombstoneTTL { |
| 264 | delete(sess.postPhysical, tx) |
| 265 | } |