celery.task.state will make the network call to fetch the task state from celery. collect() and get() are blocking methods that trying to get the result of the task. Here I don't retry but just expect the next fetching attempt will success, to make the logic simpler as we don't retry previously( tho fetching in parallel may have bigger chance to fail, wait for retry on the next loop does not hurt too much).
[ Full content available at: https://github.com/apache/incubator-airflow/pull/3830 ] This message was relayed via gitbox.apache.org for [email protected]
