Version: 0.19.3

Ingest history API

Getting the ingestion history

The following call returns the ingestion history for the feature set:

To create an ingest history containing all ingestions:

history = my_feature_set.ingest_history()
history.list()

To obtain the size of the history:

history.size

To refresh the history to contain the latest ingestions:

history.refresh()

To obtain the first or last ingestion:

first_ingest = history.first
last_ingest = history.last

To obtain a specific ingestion using an ingest id:

specific_ingest = history.get(ingest_id)

To retrieve data for a specific ingestion:

ingest.retrieve()

To get information about the ingestion like who and when did it, call:

first_ingest.ingested_at
first_ingest.ingested_records_count
first_ingest.scope
first_ingest.source
first_ingest.started_by

note

Data ingested before system version 0.0.36 is not supported for retrieval via this API.

To create an ingest history containing all ingestions:

val history = myFeatureSet.ingestHistory()
history.list()

To obtain the size of the history:

history.size

To refresh the history to contain the latest ingestions:

history.refresh()

To obtain the first or last ingestion:

val firstIngest = history.first
val lastIngest = history.last

To obtain a specific ingestion using an ingest id:

val specificIngest = history.get(ingestId)

To retrieve data for a specific ingestion:

ingest.retrieve()

To get information about the ingestion like who and when did it, call:

firstIngest.ingestedAt
firstIngest.ingestedRecordsCount
firstIngest.scope
firstIngest.source
firstIngest.startedBy

note

Data ingested before system version 0.0.36 is not supported for retrieval via this API.

Any specific ingest can be reverted. Reverting creates a new minor version with the data corresponding to the specific ingest removed.

ingest.revert()

ingest.revert()

note

This method is not allowed for derived feature sets.

There are also asynchronous variants of these methods:

ingest.revert_async()

ingest.revertAsync()

note

The above method is not allowed for derived feature sets.

Feedback