| Index: trunk/tools/editor_trends/etl/extracter.py |
| — | — | @@ -258,7 +258,7 @@ |
| 259 | 259 | def stream_raw_xml(input_queue, process_id, lock, rts):
|
| 260 | 260 | t0 = datetime.now()
|
| 261 | 261 | file_id = 0
|
| 262 | | - if rts.kaggle:
|
| | 262 | + if not rts.kaggle:
|
| 263 | 263 | cache = buffer.CSVBuffer(process_id, rts, lock)
|
| 264 | 264 |
|
| 265 | 265 | while True:
|
| — | — | @@ -284,7 +284,7 @@ |
| 285 | 285 | print 'There are %s files left in the queue' % (input_queue.qsize())
|
| 286 | 286 | t0 = t1
|
| 287 | 287 |
|
| 288 | | - if rts.kaggle:
|
| | 288 | + if not rts.kaggle:
|
| 289 | 289 | cache.close()
|
| 290 | 290 | cache.summary()
|
| 291 | 291 |
|