def METHOD_NAME(self, mp_request: MPRequest) -> MPTask:
    executor_id, executor = self._get_executor()
    task = asyncio.get_event_loop().create_task(executor.send_data_async(mp_request))
    return MPTask(executor_id=executor_id, aio_task=task, mp_request=mp_request)