Source

pomp / examples / e03_queue.py

Diff from to

examples/e03_queue.py

         downloader=dnl(timeout=3),
         pipelines=[],
         queue=WrappedQueue(source_queue, stop_event),
-        stop_on_empty_queue=True,
     )
     pomp.pump(crawler_class())
     log.debug('Stop crawler worker: %s', pid)