(theorem, topic_semaphore)
| 794 | print("Generating videos for existing plans...") |
| 795 | |
| 796 | async def process_theorem(theorem, topic_semaphore): |
| 797 | async with topic_semaphore: |
| 798 | topic = theorem['theorem'] |
| 799 | print(f"Processing topic: {topic}") |
| 800 | await video_generator.render_video_fix_code(topic, theorem['description'], max_retries=args.max_retries) |
| 801 | |
| 802 | async def main(): |
| 803 | # Use the command-line argument for topic concurrency |
no test coverage detected