- 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 row in fetch_markets(pg_config, args.user):
+ threading.Thread(target=process, args=[
+ *row, report_path, args, pg_config
+ ]).start()
+ else:
+ for row in fetch_markets(pg_config, args.user):
+ process(*row, report_path, args, pg_config)