def _create_aggregation_task(self) -> None:
        """Creates the aggregation task if it hasn't been created yet."""
        if not self._aggregation_task:
            self._aggregation_task = self.create_task(self._aggregation_task_handler())
Creates the aggregation task if it hasn't been created yet.
src/pipecat/processors/aggregators/dtmf_aggregator.py