return SVR().fit(X_train, y_train)

def set_if_success(f):
    if not f.exception():
        pass
Как избежать того, чтобы одно окно Spark Streaming блокировало другое окно, когда в обоих запущен некоторый собственный код Python