Skip to content

Commit 7d8406d

Browse files
committed
Add DeleteEntitiesIter for viur-transactionmarker
1 parent 597bfb7 commit 7d8406d

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

src/viur/core/tasks.py

+11
Original file line numberDiff line numberDiff line change
@@ -869,3 +869,14 @@ def handleEntry(cls, entry, customData):
869869
entry.delete()
870870
else:
871871
db.Delete(entry.key)
872+
873+
874+
@PeriodicTask(interval=datetime.timedelta(hours=4))
875+
def start_clear_transaction_marker():
876+
"""
877+
Removes old (expired) Transaction marker
878+
https://cloud.google.com/datastore/docs/concepts/transactions?hl=en#using_transactions
879+
"""
880+
query = db.Query("viur-transactionmarker").filter("creationdate <",
881+
datetime.datetime.now() - datetime.timedelta(seconds=270))
882+
DeleteEntitiesIter.startIterOnQuery(query)

0 commit comments

Comments
 (0)