Function batch_push

sdk/python/feast/ui_server.py:595–617

Batch push labels from CSV/parquet upload or external systems (Argilla, Label Studio).

(request: BatchPushRequest)

    @rest_app.post("/batch-push")
    def batch_push(request: BatchPushRequest):
        """Batch push labels from CSV/parquet upload or external systems (Argilla, Label Studio)."""
        try:
            df = pd.DataFrame(request.data)
            to = request.to or "online"
            if to == "online_and_offline":
                store.push(
                    request.push_source_name,
                    df,
                    to=feast.data_source.PushMode.ONLINE_AND_OFFLINE,
                )
            elif to == "offline":
                store.push(
                    request.push_source_name, df, to=feast.data_source.PushMode.OFFLINE
                )
            else:
                store.push(
                    request.push_source_name, df, to=feast.data_source.PushMode.ONLINE
                )
            return {"status": "ok", "rows_pushed": len(df)}
        except Exception:
            logger.exception("Batch push failed")
            return _safe_error_response("Batch push")

    class WebhookPushRequest(BaseModel):
        push_source_name: str