File tree Expand file tree Collapse file tree 2 files changed +4
-1
lines changed Expand file tree Collapse file tree 2 files changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -114,7 +114,8 @@ station = memphis.station(
114114 replicas = 1 , # defaults to 1
115115 idempotency_window_ms = 120000 , # defaults to 2 minutes
116116 send_poison_msg_to_dls = True , # defaults to true
117- send_schema_failed_msg_to_dls = True # defaults to true
117+ send_schema_failed_msg_to_dls = True , # defaults to true
118+ tiered_storage_enabled = False # defaults to false
118119)
119120```
120121
Original file line number Diff line number Diff line change @@ -207,6 +207,7 @@ async def station(
207207 schema_name : str = "" ,
208208 send_poison_msg_to_dls : bool = True ,
209209 send_schema_failed_msg_to_dls : bool = True ,
210+ tiered_storage_enabled : bool = False
210211 ):
211212 """Creates a station.
212213 Args:
@@ -237,6 +238,7 @@ async def station(
237238 "Schemaverse" : send_schema_failed_msg_to_dls ,
238239 },
239240 "username" : self .username ,
241+ "tiered_storage_enabled" : tiered_storage_enabled
240242 }
241243 create_station_req_bytes = json .dumps (createStationReq , indent = 2 ).encode (
242244 "utf-8"
You can’t perform that action at this time.
0 commit comments