def METHOD_NAME(self, context, payload):
    self._preflight_request_check(payload)
    try:
        yield gen.with_timeout(
            timedelta(milliseconds=context.timeout),
            self.flush(payload)
        )
    except gen.TimeoutError:
        raise TTransportException(
            type=TTransportExceptionType.TIMED_OUT,
            message='oneway timed out'
        )