async def stop(self):
        """Stop the producer and clean up resources."""
        self.is_running = False
        if self.producer_task:
            # Give producer a chance to finish gracefully
            try:
                await asyncio.wait_for(self.producer_task, timeout=5.0)
            except asyncio.TimeoutError:
                self.logger.warning("Producer task did not complete in time, cancelling")
                self.producer_task.cancel()
                try:
                    await self.producer_task
                except asyncio.CancelledError:
                    pass
Stop the producer and clean up resources.
backend/airweave/platform/sync/stream.py