擅长:python、mysql、java
<p>我通过运行一个计划任务来解决这个问题,该任务运行具有所需到期时间的已定义任务:</p>
<pre><code>@shared_task(bind=True, queue='q1', max_retries=3)
def parent_task(self, arg1):
child_task.apply_async(kwargs={'arg1': arg1}, expires=86400)
@shared_task(bind=True, queue='q1', max_retries=3)
def child_task(self, arg1):
pass
</code></pre>