from stream_predictor.stream_predictor import streams