@@ -9115,7 +9115,7 @@ def __init__(path: str,
9115
9115
9116
9116
A base CSV source that reads data from a single CSV file.
9117
9117
9118
- Best used with :class: `quixstreams.sinks.csv.CSVSink`.
9118
+ Best used with `quixstreams.sinks.csv.CSVSink`.
9119
9119
9120
9120
Required columns: key, value
9121
9121
Optional columns: timestamp
@@ -9179,7 +9179,7 @@ def raise_for_error() -> None
9179
9179
9180
9180
[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L115)
9181
9181
9182
- Raise a :class: `quixstreams.sources.manager.SourceException`
9182
+ Raise a `quixstreams.sources.manager.SourceException`
9183
9183
if the child process was terminated with an exception.
9184
9184
9185
9185
<a id="quixstreams.sources.manager.SourceProcess.stop"></a>
@@ -9544,11 +9544,11 @@ def serialize(key: Optional[object] = None,
9544
9544
9545
9545
[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/base.py#L233)
9546
9546
9547
- Serialize data to bytes using the producer topic serializers and return a :class: `quixstreams.models.messages.KafkaMessage` .
9547
+ Serialize data to bytes using the producer topic serializers and return a `quixstreams.models.messages.KafkaMessage`.
9548
9548
9549
9549
**Returns**:
9550
9550
9551
- :class: `quixstreams.models.messages.KafkaMessage`
9551
+ `quixstreams.models.messages.KafkaMessage`
9552
9552
9553
9553
<a id="quixstreams.sources.base.Source.produce"></a>
9554
9554
@@ -9607,7 +9607,7 @@ The default topic will not be used if the topic has already been provided to the
9607
9607
9608
9608
**Returns**:
9609
9609
9610
- `:class:` quixstreams.models.topics.Topic`
9610
+ `quixstreams.models.topics.Topic`
9611
9611
9612
9612
<a id="quixstreams.rowconsumer"></a>
9613
9613
0 commit comments