--- /dev/null
+-- claim a specific topic needing the content fetched
+INSERT INTO topic_fetch_in_progress (id, claimant, claimed, claim_expires)
+VALUES (:topicId, :claimant, strftime('%s', 'now'), strftime('%s', 'now') + :claimTimeoutSeconds)
+ON CONFLICT (id) DO UPDATE
+SET
+ claimant = :claimant,
+ claimed = strftime('%s', 'now'),
+ claim_expires = strftime('%s', 'now') + :claimTimeoutSeconds