使用inmemory Breaked in芹菜时，同步完成所有挂起的任务

Question

出于测试目的，我使用内存中的芹菜代理："memory://localhost/"。我可以启动一个worker来执行以下任务：

app = Celery('celery_app')
worker = app.Worker(app=app, pool='solo', concurrency=1)
thread = threading.Thread(target=worker.start)
thread.daemon = True
thread.start()

但我怎样才能更好地控制它呢？我希望以阻塞/同步方式执行所有任务，以便我的测试能够在运行任务之前和之后对系统的状态做出强有力的断言

我知道，如果任务产生更多的任务，这可能会永远持续下去，这没关系