@@ -293,7 +293,8 @@ workspace data dict if topic search success, else None
293
293
```python
294
294
def create_topics(topics: List[Topic],
295
295
timeout: Optional[float] = None,
296
- finalize_timeout: Optional[float] = None)
296
+ finalize_timeout: Optional[float] = None,
297
+ prepend: bool = True)
297
298
```
298
299
299
300
[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/platforms/quix/config.py#L369)
@@ -306,6 +307,7 @@ Create topics in a Quix cluster.
306
307
- `timeout`: response timeout (seconds); Default 30
307
308
- `finalize_timeout`: topic finalization timeout (seconds); Default 60
308
309
marked as "Ready" (and thus ready to produce to/consume from).
310
+ - `prepend`: whether to prepend workspace_id during creation attempt.
309
311
310
312
<a id="quixstreams.platforms.quix.config.QuixKafkaConfigsBuilder.get_topic"></a>
311
313
@@ -316,7 +318,7 @@ def get_topic(topic_name: str,
316
318
timeout: Optional[float] = None) -> Optional[dict]
317
319
```
318
320
319
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/platforms/quix/config.py#L419 )
321
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/platforms/quix/config.py#L421 )
320
322
321
323
return the topic ID (the actual cluster topic name) if it exists, else None
322
324
@@ -342,7 +344,7 @@ def confirm_topics_exist(topics: Union[List[Topic], List[str]],
342
344
timeout: Optional[float] = None)
343
345
```
344
346
345
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/platforms/quix/config.py#L451 )
347
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/platforms/quix/config.py#L453 )
346
348
347
349
Confirm whether the desired set of topics exists in the Quix workspace.
348
350
@@ -359,7 +361,7 @@ Confirm whether the desired set of topics exists in the Quix workspace.
359
361
def get_application_config(consumer_group_id: str) -> QuixApplicationConfig
360
362
```
361
363
362
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/platforms/quix/config.py#L483 )
364
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/platforms/quix/config.py#L485 )
363
365
364
366
Get all the necessary attributes for an Application to run on Quix Cloud.
365
367
0 commit comments