Method run_task

src/process/processor.py:231–232

(self, task: Any)

            raise ValueError(f"Symbol {symbol} not found in assets file")

    async def run_task(self, task: Any):
        return await task.run()

    async def run(self):
        """ Run the aggregation processor.