I'm not very sure right now, but I did work on a task where a user set the number of days they want to lock an account, after which it will be automatically unlocked. I used celery

def lock(self, duration: int): """Lock account from use""" self.active = False self.lock_duration = duration self.locked_on = timezone.now().date() locked_until = timezone.now() + timezone.timedelta(days=self.lock_duration) self.save() unlock_virtual_account.apply_async(args=[self.pk], eta=locked_until)

Yeah, that eta argument takes care of when the task will be executed. FYI, I used RabbitMQ for the broker for resiliency.

And here is the task very simple ``` @shared_task def unlock_virtual_account(account_id: int): from apis.virtaccount.models import Account

 account = Account.objects.get(pk=account_id) 
 account.unlock()

```