From 8cfbb8510ce9bebb1b22889629adb4d1144e88e2 Mon Sep 17 00:00:00 2001 From: jrconlin Date: Mon, 24 Aug 2020 16:00:47 +0000 Subject: [PATCH] f add conditions to `batches` --- tools/spanner/purge_ttl.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tools/spanner/purge_ttl.py b/tools/spanner/purge_ttl.py index 84215086..c2473a72 100644 --- a/tools/spanner/purge_ttl.py +++ b/tools/spanner/purge_ttl.py @@ -103,7 +103,11 @@ def spanner_purge(args): if args.mode in ["batches", "both"]: # Delete Batches. Also deletes child batch_bsos rows (INTERLEAVE # IN PARENT batches ON DELETE CASCADE) - batch_query = 'DELETE FROM batches WHERE {}'.format(expiry_condition) + batch_query = add_conditions( + args, + 'DELETE FROM batches WHERE {}'.format(expiry_condition), + prefix, + ) deleter( database, name="batches",