def getlimit(stream):
 pipe = Pipeline()
 pipe.append(Limit())
 result = pipe(stream)
 try:
  return int(result)
 except ValueError:
  return result

def getlimit ( stream ) : pipe = Pipeline ( ) pipe . append ( Limit ( ) ) result = pipe ( stream ) try : return int ( result ) except ValueError : return result
function that return the limit of a input sql .