@@ -494,7 +494,7 @@ Default: the source default
494
494
def run(dataframe: Optional[StreamingDataFrame] = None )
495
495
```
496
496
497
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L679 )
497
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L685 )
498
498
499
499
Start processing data from Kafka using provided `StreamingDataFrame`
500
500
@@ -530,7 +530,7 @@ app.run()
530
530
def setup_topics()
531
531
```
532
532
533
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L802 )
533
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L808 )
534
534
535
535
Validate and create the topics
536
536
@@ -542,7 +542,7 @@ Validate and create the topics
542
542
class ApplicationConfig(BaseSettings)
543
543
```
544
544
545
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L978 )
545
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L984 )
546
546
547
547
Immutable object holding the application configuration
548
548
@@ -565,7 +565,7 @@ def settings_customise_sources(
565
565
) -> Tuple[PydanticBaseSettingsSource, ... ]
566
566
```
567
567
568
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1013 )
568
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1019 )
569
569
570
570
Included to ignore reading/ setting values from the environment
571
571
@@ -579,7 +579,7 @@ Included to ignore reading/setting values from the environment
579
579
def copy(** kwargs) -> Self
580
580
```
581
581
582
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1026 )
582
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main/ quixstreams/ app.py# L1032 )
583
583
584
584
Update the application config and return a copy
585
585
0 commit comments