WARNING: If you're reading this in 2021 or later, you're likely better served by reading:
(This gist was created in 2013 and targeted the legacy GOPATH mode.)
$ ssh -A vm
$ git config --global url."[email protected]:".insteadOf "https://github.com/"
| from tasks import task1 | |
| def get_results(queries): | |
| query_procs = task1.delay(queries).get().join() | |
| results = [] | |
| for query_proc in query_procs: | |
| # while the following iterate() is happening, the other query_procs are ignored. | |
| # ideas on iterating over all of them at once? | |
| for result in query_proc.iterate(): | |
| yield result |
| from celery.result import AsyncResult | |
| from celery.execute import send_task | |
| def get_results(queries): | |
| result = send_task('task1',queries) | |
| results = result.get() | |
| #this does not return ids until _after_ all the tasks are complete, for some reason. | |
| while results: | |
| #pop first off queue, this will shorten the list and eventually break out of while | |
| first_id = results.pop(0) |