LakeFSCommitSensor

LakeFS

Executes a get branch operation until that branch was committed.

View on GitHub

Last Updated: May. 30, 2022

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_idstrThe connection to run the sensor against
repostrThe lakeFS repo.
branchstrThe branch to sense for.
prev_commit_idstrIf present, previous last commit ID on branch; wait until it changes.

Documentation

Executes a get branch operation until that branch was committed.

Was this page helpful?