async def start(self):
        """Start the background producer task.

        Runs the producer in a separate task so that it can run independently of the consumer.
        """
        self.producer_task = asyncio.create_task(self._producer())
Start the background producer task.

        Runs the producer in a separate task so that it can run independently of the consumer.
        
backend/airweave/platform/sync/stream.py