async def METHOD_NAME(self):
    fake_task = mock.Mock(host="fake_host", ports=[])
    actual = await self.drain_method.for_each_registration(
        task=fake_task, func=self._async_id
    )
    assert actual is None