| Index: trunk/tools/editor_trends/etl/store.py |
| — | — | @@ -100,7 +100,11 @@ |
| 101 | 101 | def store_articles(tasks, rts): |
| 102 | 102 | db = storage.init_database(rts.storage, rts.dbname, rts.articles_raw) |
| 103 | 103 | while True: |
| 104 | | - filename = tasks.get(block=False) |
| | 104 | + try: |
| | 105 | + filename = tasks.get(block=False) |
| | 106 | + except Empty: |
| | 107 | + pass |
| | 108 | + |
| 105 | 109 | if filename == None: |
| 106 | 110 | break |
| 107 | 111 | print 'Processing %s...' % filename |