We can use messaging for this: send a message that triggers the clean up process, deduplicated by the id given by the time (perhaps date) for which it was trigged.