@@ -53,10 +53,12 @@ def source(
5353 self ,
5454 * ,
5555 account_id : str ,
56- bucket : str | Omit = omit ,
56+ bucket : str ,
57+ secret : connectivity_precheck_source_params .R2SlurperS3SourceSchemaSecret ,
58+ vendor : Literal ["s3" ],
5759 endpoint : Optional [str ] | Omit = omit ,
58- secret : connectivity_precheck_source_params . R2SlurperS3SourceSchemaSecret | Omit = omit ,
59- vendor : Literal [ "s3" ] | Omit = omit ,
60+ path_prefix : Optional [ str ] | Omit = omit ,
61+ region : Optional [ str ] | Omit = omit ,
6062 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
6163 # The extra values given here take precedence over values defined on the client or passed to this method.
6264 extra_headers : Headers | None = None ,
@@ -83,9 +85,10 @@ def source(
8385 self ,
8486 * ,
8587 account_id : str ,
86- bucket : str | Omit = omit ,
87- secret : connectivity_precheck_source_params .R2SlurperGcsSourceSchemaSecret | Omit = omit ,
88- vendor : Literal ["gcs" ] | Omit = omit ,
88+ bucket : str ,
89+ secret : connectivity_precheck_source_params .R2SlurperGcsSourceSchemaSecret ,
90+ vendor : Literal ["gcs" ],
91+ path_prefix : Optional [str ] | Omit = omit ,
8992 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
9093 # The extra values given here take precedence over values defined on the client or passed to this method.
9194 extra_headers : Headers | None = None ,
@@ -112,10 +115,11 @@ def source(
112115 self ,
113116 * ,
114117 account_id : str ,
115- bucket : str | Omit = omit ,
118+ bucket : str ,
119+ secret : connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret ,
120+ vendor : Provider ,
116121 jurisdiction : Literal ["default" , "eu" , "fedramp" ] | Omit = omit ,
117- secret : connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret | Omit = omit ,
118- vendor : Provider | Omit = omit ,
122+ path_prefix : Optional [str ] | Omit = omit ,
119123 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
120124 # The extra values given here take precedence over values defined on the client or passed to this method.
121125 extra_headers : Headers | None = None ,
@@ -137,18 +141,19 @@ def source(
137141 """
138142 ...
139143
140- @required_args (["account_id" ])
144+ @required_args (["account_id" , "bucket" , "secret" , "vendor" ])
141145 def source (
142146 self ,
143147 * ,
144148 account_id : str ,
145- bucket : str | Omit = omit ,
146- endpoint : Optional [str ] | Omit = omit ,
149+ bucket : str ,
147150 secret : connectivity_precheck_source_params .R2SlurperS3SourceSchemaSecret
148151 | connectivity_precheck_source_params .R2SlurperGcsSourceSchemaSecret
149- | connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret
150- | Omit = omit ,
151- vendor : Literal ["s3" ] | Literal ["gcs" ] | Provider | Omit = omit ,
152+ | connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret ,
153+ vendor : Literal ["s3" ] | Literal ["gcs" ] | Provider ,
154+ endpoint : Optional [str ] | Omit = omit ,
155+ path_prefix : Optional [str ] | Omit = omit ,
156+ region : Optional [str ] | Omit = omit ,
152157 jurisdiction : Literal ["default" , "eu" , "fedramp" ] | Omit = omit ,
153158 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
154159 # The extra values given here take precedence over values defined on the client or passed to this method.
@@ -164,9 +169,11 @@ def source(
164169 body = maybe_transform (
165170 {
166171 "bucket" : bucket ,
167- "endpoint" : endpoint ,
168172 "secret" : secret ,
169173 "vendor" : vendor ,
174+ "endpoint" : endpoint ,
175+ "path_prefix" : path_prefix ,
176+ "region" : region ,
170177 "jurisdiction" : jurisdiction ,
171178 },
172179 connectivity_precheck_source_params .ConnectivityPrecheckSourceParams ,
@@ -187,10 +194,10 @@ def target(
187194 self ,
188195 * ,
189196 account_id : str ,
190- bucket : str | Omit = omit ,
197+ bucket : str ,
198+ secret : connectivity_precheck_target_params .Secret ,
199+ vendor : Provider ,
191200 jurisdiction : Literal ["default" , "eu" , "fedramp" ] | Omit = omit ,
192- secret : connectivity_precheck_target_params .Secret | Omit = omit ,
193- vendor : Provider | Omit = omit ,
194201 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
195202 # The extra values given here take precedence over values defined on the client or passed to this method.
196203 extra_headers : Headers | None = None ,
@@ -217,9 +224,9 @@ def target(
217224 body = maybe_transform (
218225 {
219226 "bucket" : bucket ,
220- "jurisdiction" : jurisdiction ,
221227 "secret" : secret ,
222228 "vendor" : vendor ,
229+ "jurisdiction" : jurisdiction ,
223230 },
224231 connectivity_precheck_target_params .ConnectivityPrecheckTargetParams ,
225232 ),
@@ -261,10 +268,12 @@ async def source(
261268 self ,
262269 * ,
263270 account_id : str ,
264- bucket : str | Omit = omit ,
271+ bucket : str ,
272+ secret : connectivity_precheck_source_params .R2SlurperS3SourceSchemaSecret ,
273+ vendor : Literal ["s3" ],
265274 endpoint : Optional [str ] | Omit = omit ,
266- secret : connectivity_precheck_source_params . R2SlurperS3SourceSchemaSecret | Omit = omit ,
267- vendor : Literal [ "s3" ] | Omit = omit ,
275+ path_prefix : Optional [ str ] | Omit = omit ,
276+ region : Optional [ str ] | Omit = omit ,
268277 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
269278 # The extra values given here take precedence over values defined on the client or passed to this method.
270279 extra_headers : Headers | None = None ,
@@ -291,9 +300,10 @@ async def source(
291300 self ,
292301 * ,
293302 account_id : str ,
294- bucket : str | Omit = omit ,
295- secret : connectivity_precheck_source_params .R2SlurperGcsSourceSchemaSecret | Omit = omit ,
296- vendor : Literal ["gcs" ] | Omit = omit ,
303+ bucket : str ,
304+ secret : connectivity_precheck_source_params .R2SlurperGcsSourceSchemaSecret ,
305+ vendor : Literal ["gcs" ],
306+ path_prefix : Optional [str ] | Omit = omit ,
297307 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
298308 # The extra values given here take precedence over values defined on the client or passed to this method.
299309 extra_headers : Headers | None = None ,
@@ -320,10 +330,11 @@ async def source(
320330 self ,
321331 * ,
322332 account_id : str ,
323- bucket : str | Omit = omit ,
333+ bucket : str ,
334+ secret : connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret ,
335+ vendor : Provider ,
324336 jurisdiction : Literal ["default" , "eu" , "fedramp" ] | Omit = omit ,
325- secret : connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret | Omit = omit ,
326- vendor : Provider | Omit = omit ,
337+ path_prefix : Optional [str ] | Omit = omit ,
327338 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
328339 # The extra values given here take precedence over values defined on the client or passed to this method.
329340 extra_headers : Headers | None = None ,
@@ -345,18 +356,19 @@ async def source(
345356 """
346357 ...
347358
348- @required_args (["account_id" ])
359+ @required_args (["account_id" , "bucket" , "secret" , "vendor" ])
349360 async def source (
350361 self ,
351362 * ,
352363 account_id : str ,
353- bucket : str | Omit = omit ,
354- endpoint : Optional [str ] | Omit = omit ,
364+ bucket : str ,
355365 secret : connectivity_precheck_source_params .R2SlurperS3SourceSchemaSecret
356366 | connectivity_precheck_source_params .R2SlurperGcsSourceSchemaSecret
357- | connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret
358- | Omit = omit ,
359- vendor : Literal ["s3" ] | Literal ["gcs" ] | Provider | Omit = omit ,
367+ | connectivity_precheck_source_params .R2SlurperR2SourceSchemaSecret ,
368+ vendor : Literal ["s3" ] | Literal ["gcs" ] | Provider ,
369+ endpoint : Optional [str ] | Omit = omit ,
370+ path_prefix : Optional [str ] | Omit = omit ,
371+ region : Optional [str ] | Omit = omit ,
360372 jurisdiction : Literal ["default" , "eu" , "fedramp" ] | Omit = omit ,
361373 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
362374 # The extra values given here take precedence over values defined on the client or passed to this method.
@@ -372,9 +384,11 @@ async def source(
372384 body = await async_maybe_transform (
373385 {
374386 "bucket" : bucket ,
375- "endpoint" : endpoint ,
376387 "secret" : secret ,
377388 "vendor" : vendor ,
389+ "endpoint" : endpoint ,
390+ "path_prefix" : path_prefix ,
391+ "region" : region ,
378392 "jurisdiction" : jurisdiction ,
379393 },
380394 connectivity_precheck_source_params .ConnectivityPrecheckSourceParams ,
@@ -395,10 +409,10 @@ async def target(
395409 self ,
396410 * ,
397411 account_id : str ,
398- bucket : str | Omit = omit ,
412+ bucket : str ,
413+ secret : connectivity_precheck_target_params .Secret ,
414+ vendor : Provider ,
399415 jurisdiction : Literal ["default" , "eu" , "fedramp" ] | Omit = omit ,
400- secret : connectivity_precheck_target_params .Secret | Omit = omit ,
401- vendor : Provider | Omit = omit ,
402416 # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
403417 # The extra values given here take precedence over values defined on the client or passed to this method.
404418 extra_headers : Headers | None = None ,
@@ -425,9 +439,9 @@ async def target(
425439 body = await async_maybe_transform (
426440 {
427441 "bucket" : bucket ,
428- "jurisdiction" : jurisdiction ,
429442 "secret" : secret ,
430443 "vendor" : vendor ,
444+ "jurisdiction" : jurisdiction ,
431445 },
432446 connectivity_precheck_target_params .ConnectivityPrecheckTargetParams ,
433447 ),
0 commit comments