aligned.data_source.stream_data_source.SinkableDataSource

class documentation

class SinkableDataSource: (source)

Known subclasses: aligned.sources.redis.RedisStreamSource

View In Hierarchy

Undocumented

Async Method write_to_stream Undocumented
async def write_to_stream(self, job: RetrievalJob): (source) ΒΆ
overridden in aligned.sources.redis.RedisStreamSource

Undocumented