From 5661ce44b20df75f2973523cffd9a82fe39f67b3 Mon Sep 17 00:00:00 2001 From: datechnoman Date: Fri, 26 Jan 2024 07:14:25 +0000 Subject: [PATCH] Updated loop issue --- warc_wat_url_processor.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/warc_wat_url_processor.py b/warc_wat_url_processor.py index cedf98c..089f8a5 100644 --- a/warc_wat_url_processor.py +++ b/warc_wat_url_processor.py @@ -102,7 +102,15 @@ def main(): futures = [executor.submit(download_and_process_file, url) for url in urls] # Wait for all downloads and processing to complete before starting the next iteration - as_completed(futures) + completed_futures, _ = wait(futures) + + # Process results from completed futures + for completed_future in completed_futures: + try: + result = completed_future.result() + # Process the result if needed + except Exception as e: + print(f"Error in processing future: {e}") if __name__ == "__main__": main()