Method execute_code

projects/code_genesis/workflow/coding.py:645–704

(self, inputs, **kwargs)

        await programmer.run(messages)

    async def execute_code(self, inputs, **kwargs):
        await self._init_lsp_servers()
        with open(os.path.join(self.output_dir, 'topic.txt')) as f:
            topic = f.read()
        with open(os.path.join(self.output_dir, 'user_story.txt')) as f:
            user_story = f.read()
        with open(os.path.join(self.output_dir, 'framework.txt')) as f:
            framework = f.read()
        with open(os.path.join(self.output_dir, 'protocol.txt')) as f:
            protocol = f.read()
        with open(os.path.join(self.output_dir, 'file_order.txt')) as f:
            file_order = f.read()

        file_orders = self.construct_file_orders()
        file_relation = OrderedDict()
        self.refresh_file_status(file_relation)
        shutil.rmtree(
            os.path.join(self.output_dir, 'locks'), ignore_errors=True)

        for idx, files in enumerate(file_orders):
            while True:
                files = self.filter_done_files(files)
                files = self.find_description(files)
                self.construct_file_information(file_relation)
                if not files:
                    break

                if idx == 0:
                    last_batch = 'You are the first batch.'
                    next_batch = '\n'.join(file_orders[idx + 1])
                if idx == len(file_orders) - 1:
                    last_batch = '\n'.join(file_orders[idx - 1])
                    next_batch = 'You are the last batch.'
                else:
                    last_batch = '\n'.join(file_orders[idx - 1])
                    next_batch = '\n'.join(file_orders[idx + 1])

                tasks = [
                    self.write_code(
                        topic,
                        user_story,
                        framework,
                        protocol,
                        file_order,
                        name,
                        description,
                        index=idx,
                        last_batch=last_batch,
                        siblings='\n'.join(set(files) - {name}),
                        next_batch=next_batch)
                    for name, description in files.items()
                ]

                await asyncio.gather(*tasks, return_exceptions=True)

            self.refresh_file_status(file_relation)

        self.construct_file_information(file_relation)