@@ -9043,7 +9043,7 @@ app.run(dataframe=df)
9043
9043
class ApplicationConfig(BaseSettings)
9044
9044
```
9045
9045
9046
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/app.py#L1049 )
9046
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/app.py#L1056 )
9047
9047
9048
9048
Immutable object holding the application configuration
9049
9049
@@ -9064,7 +9064,7 @@ def settings_customise_sources(
9064
9064
) -> Tuple[PydanticBaseSettingsSource, ...]
9065
9065
```
9066
9066
9067
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/app.py#L1083 )
9067
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/app.py#L1090 )
9068
9068
9069
9069
Included to ignore reading/setting values from the environment
9070
9070
@@ -9076,7 +9076,7 @@ Included to ignore reading/setting values from the environment
9076
9076
def copy(**kwargs) -> Self
9077
9077
```
9078
9078
9079
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/app.py#L1096 )
9079
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/app.py#L1103 )
9080
9080
9081
9081
Update the application config and return a copy
9082
9082
@@ -9160,7 +9160,7 @@ Some methods are designed to be used from the parent process, and others from th
9160
9160
def run() -> None
9161
9161
```
9162
9162
9163
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L48 )
9163
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L53 )
9164
9164
9165
9165
An entrypoint of the child process.
9166
9166
@@ -9177,7 +9177,7 @@ Responsible for:
9177
9177
def raise_for_error() -> None
9178
9178
```
9179
9179
9180
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L108 )
9180
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L115 )
9181
9181
9182
9182
Raise a :class:`quixstreams.sources.manager.SourceException`
9183
9183
if the child process was terminated with an exception.
@@ -9190,7 +9190,7 @@ if the child process was terminated with an exception.
9190
9190
def stop()
9191
9191
```
9192
9192
9193
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L129 )
9193
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L136 )
9194
9194
9195
9195
Handle shutdown of the source and its subprocess.
9196
9196
@@ -9206,7 +9206,7 @@ is still alive, it will kill it with a SIGKILL.
9206
9206
class SourceManager()
9207
9207
```
9208
9208
9209
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L152 )
9209
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L159 )
9210
9210
9211
9211
Class managing the sources registered with the app
9212
9212
@@ -9220,7 +9220,7 @@ Sources run in their separate process pay attention about cross-process communic
9220
9220
def register(source: BaseSource)
9221
9221
```
9222
9222
9223
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L162 )
9223
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L169 )
9224
9224
9225
9225
Register a new source in the manager.
9226
9226
@@ -9234,7 +9234,7 @@ Each source need to already be configured, can't reuse a topic and must be uniqu
9234
9234
def raise_for_error() -> None
9235
9235
```
9236
9236
9237
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L201 )
9237
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L209 )
9238
9238
9239
9239
Raise an exception if any process has stopped with an exception
9240
9240
@@ -9246,7 +9246,7 @@ Raise an exception if any process has stopped with an exception
9246
9246
def is_alive() -> bool
9247
9247
```
9248
9248
9249
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L208 )
9249
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L216 )
9250
9250
9251
9251
Check if any process is alive
9252
9252
@@ -9262,7 +9262,7 @@ True if at least one process is alive
9262
9262
class SourceException(Exception)
9263
9263
```
9264
9264
9265
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L231 )
9265
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/sources/manager.py#L238 )
9266
9266
9267
9267
Raised in the parent process when a source finish with an exception
9268
9268
0 commit comments