async def queue_frame(self, frame: Frame):
        """Queue a single frame to be pushed down the pipeline.

        Args:
            frame: The frame to be processed.
        """
        await self._push_queue.put(frame)
Queue a single frame to be pushed down the pipeline.

        Args:
            frame: The frame to be processed.
        
src/pipecat/pipeline/task.py