LakeFSUploadOperator
LakeFSUpload an object to a lakeFS repo.
Access Instructions
Install the LakeFS provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
lakefs_conn_idstrconnection to run the operator with
repostrThe lakeFS repo for the desired object.
branchstrThe branch name for the desired object.
pathThe path for the desired object.
msgstr
contenttyping.IOContents of the desired object.
Documentation
Upload an object to a lakeFS repo.