如何在 Gearman 中提交非阻塞作业？

Question

我想使用result = gearman_client.submit_job("reverse_task", "Hello World!", wait_until_complete=False) 向 Gearman 作业服务器提交非阻塞作业。但是，result.state 始终是 'CREATED'，result.complete 始终是 False。如果我将wait_until_complete 更改为True，那么一切正常。这太连线了。有人可以帮忙吗？

Answer 1

正如 python-gearman 描述的here，您应该使用gearman_client.wait_until_jobs_completed([result]) 等待所有作业完成，而不是在while 循环中检查result.complete。