async def METHOD_NAME(self) -> None:
    """
    Cleanup called once per parallel test instance.
    Used to cleanup state specific to this test instance.
    """
    if self.args.sync:
        self.stop_events_sync()
        self._processing.join()
    else:
        await self.stop_events_async()
        await self._processing
    try:
        raise self._error
    except TypeError:
        pass