Source code for feast.infra.materialization.contrib.bytewax.bytewax_materialization_task

from feast.infra.materialization.batch_materialization_engine import MaterializationTask


[docs]class BytewaxMaterializationTask(MaterializationTask): def __init__(self, project, feature_view, start_date, end_date, tqdm): self.project = project self.feature_view = feature_view self.start_date = start_date self.end_date = end_date self.tqdm = tqdm