def collect_and_train(df):
    y, X = zip(*((p.label, p.features.toArray()) for p in df.collect()))
Как избежать того, чтобы одно окно Spark Streaming блокировало другое окно, когда в обоих запущен некоторый собственный код Python