- for market_config, user_id in fetch_markets(pg_config, args.user):
- process(market_config, user_id, report_path, args)
+ if args.parallel:
+ import threading
+ market.Portfolio.start_worker()
+
+ for market_config, user_id in fetch_markets(pg_config, args.user):
+ threading.Thread(target=process, args=[market_config, user_id, report_path, args]).start()
+ else:
+ for market_config, user_id in fetch_markets(pg_config, args.user):
+ process(market_config, user_id, report_path, args)