Как подать неблокирующую работу в 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 описан здесь, вы должны использовать gearman_client.wait_until_jobs_completed([result]) дождаться завершения всех заданий, а не проверять result.complete в то время как цикл.