diff options
| author | Cédric Bonhomme <cedric@cedricbonhomme.org> | 2015-02-12 08:04:16 +0100 |
|---|---|---|
| committer | Cédric Bonhomme <cedric@cedricbonhomme.org> | 2015-02-12 08:04:16 +0100 |
| commit | d594b1e928661bd5d284b75431474eefe61e919a (patch) | |
| tree | 289123c22f102b7b34d1934b3f48fb6ab735a729 | |
| parent | Time to sleep. (diff) | |
| download | newspipe-d594b1e928661bd5d284b75431474eefe61e919a.tar.gz newspipe-d594b1e928661bd5d284b75431474eefe61e919a.tar.bz2 newspipe-d594b1e928661bd5d284b75431474eefe61e919a.zip | |
Minor changes in the crawler (test of asyncio.async).
| -rw-r--r-- | pyaggr3g470r/crawler.py | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/pyaggr3g470r/crawler.py b/pyaggr3g470r/crawler.py index f7b8ef49..f2ae1599 100644 --- a/pyaggr3g470r/crawler.py +++ b/pyaggr3g470r/crawler.py @@ -192,8 +192,9 @@ def insert_database(user, feed): @asyncio.coroutine def init_process(user, feed): - data = yield from asyncio.async(insert_database(user, feed)) + articles = yield from asyncio.async(insert_database(user, feed)) #print('inserted articles for {}'.format(feed.title)) + return articles def retrieve_feed(user, feed_id=None): """ @@ -212,8 +213,9 @@ def retrieve_feed(user, feed_id=None): # 2 - Fetch the feeds. loop = asyncio.get_event_loop() - f = asyncio.wait([init_process(user, feed) for feed in feeds]) - loop.run_until_complete(f) + tasks = [init_process(user, feed) for feed in feeds] + #tasks = [asyncio.async(init_process(user, feed)) for feed in feeds] + loop.run_until_complete(asyncio.wait(tasks)) """ # 3 - Indexation |