aligned.sources.redis.RedisSource

class documentation

class RedisSource(FeatureSource, WritableFeatureSource): (source)

View In Hierarchy

Undocumented

Method all_for Undocumented
Method features_for Undocumented
Async Method insert Undocumented
Async Method upsert Undocumented
Class Variable batch_size Undocumented
Class Variable config Undocumented

Inherited from FeatureSource:

Async Method freshness_for Undocumented

Inherited from WritableFeatureSource (via FeatureSource):

Async Method overwrite Undocumented
def all_for(self, request: FeatureRequest, limit: int | None = None) -> RetrivalJob: (source)

Undocumented

def features_for(self, facts: RetrivalJob, request: FeatureRequest) -> RetrivalJob: (source)
overrides aligned.feature_source.FeatureSource.features_for

Undocumented

async def insert(self, job: RetrivalJob, request: RetrivalRequest): (source)
overrides aligned.feature_source.WritableFeatureSource.insert

Undocumented

async def upsert(self, job: RetrivalJob, request: RetrivalRequest): (source)
overrides aligned.feature_source.WritableFeatureSource.upsert

Undocumented

batch_size: int = (source)

Undocumented

config: RedisConfig = (source)

Undocumented