async def METHOD_NAME(self, sources: Sources):
    x_cols: Dict[str, Any] = {feature: [] for feature in self.features}
    y_cols = []
    async for record in sources.with_features(self.all_features):
        for feature, results in record.features(self.features).items():
            x_cols[feature].append(self.np.array(results))
        y_cols.append(record.feature(self.parent.config.predict.name))
    y_cols = self.np.array(y_cols)
    for feature in x_cols:
        x_cols[feature] = self.np.array(x_cols[feature])
    return x_cols, y_cols