@@ -129,6 +129,7 @@ def watch(
129
129
* ,
130
130
environment_id : str ,
131
131
connect_protocol_version : Literal [1 ],
132
+ organization : bool | NotGiven = NOT_GIVEN ,
132
133
connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
133
134
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
134
135
# The extra values given here take precedence over values defined on the client or passed to this method.
@@ -148,6 +149,11 @@ def watch(
148
149
149
150
connect_protocol_version: Define the version of the Connect protocol
150
151
152
+ organization: Organization scope produces events for all projects, runners and environments
153
+
154
+ the caller can see within their organization. No task, task execution or service
155
+ events are produed.
156
+
151
157
connect_timeout_ms: Define the timeout, in ms
152
158
153
159
extra_headers: Send extra headers
@@ -166,6 +172,7 @@ def watch(
166
172
* ,
167
173
organization : bool ,
168
174
connect_protocol_version : Literal [1 ],
175
+ environment_id : str | NotGiven = NOT_GIVEN ,
169
176
connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
170
177
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
171
178
# The extra values given here take precedence over values defined on the client or passed to this method.
@@ -185,6 +192,11 @@ def watch(
185
192
186
193
connect_protocol_version: Define the version of the Connect protocol
187
194
195
+ environment_id: Environment scope produces events for the environment itself, all tasks, task
196
+ executions,
197
+
198
+ and services associated with that environment.
199
+
188
200
connect_timeout_ms: Define the timeout, in ms
189
201
190
202
extra_headers: Send extra headers
@@ -197,14 +209,61 @@ def watch(
197
209
"""
198
210
...
199
211
200
- @required_args ([ "environment_id" , "connect_protocol_version" ], [ "organization" , "connect_protocol_version" ])
212
+ @overload
201
213
def watch (
202
214
self ,
203
215
* ,
204
- environment_id : str | NotGiven = NOT_GIVEN ,
205
216
connect_protocol_version : Literal [1 ],
217
+ environment_id : str | NotGiven = NOT_GIVEN ,
218
+ organization : bool | NotGiven = NOT_GIVEN ,
206
219
connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
220
+ # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
221
+ # The extra values given here take precedence over values defined on the client or passed to this method.
222
+ extra_headers : Headers | None = None ,
223
+ extra_query : Query | None = None ,
224
+ extra_body : Body | None = None ,
225
+ timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
226
+ ) -> EventWatchResponse :
227
+ """
228
+ WatchEvents streams all requests events to the client
229
+
230
+ Args:
231
+ connect_protocol_version: Define the version of the Connect protocol
232
+
233
+ environment_id: Environment scope produces events for the environment itself, all tasks, task
234
+ executions,
235
+
236
+ and services associated with that environment.
237
+
238
+ organization: Organization scope produces events for all projects, runners and environments
239
+
240
+ the caller can see within their organization. No task, task execution or service
241
+ events are produed.
242
+
243
+ connect_timeout_ms: Define the timeout, in ms
244
+
245
+ extra_headers: Send extra headers
246
+
247
+ extra_query: Add additional query parameters to the request
248
+
249
+ extra_body: Add additional JSON properties to the request
250
+
251
+ timeout: Override the client-level default timeout for this request, in seconds
252
+ """
253
+ ...
254
+
255
+ @required_args (
256
+ ["environment_id" , "connect_protocol_version" ],
257
+ ["organization" , "connect_protocol_version" ],
258
+ ["connect_protocol_version" ],
259
+ )
260
+ def watch (
261
+ self ,
262
+ * ,
263
+ environment_id : str | NotGiven = NOT_GIVEN ,
264
+ connect_protocol_version : Literal [1 ],
207
265
organization : bool | NotGiven = NOT_GIVEN ,
266
+ connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
208
267
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
209
268
# The extra values given here take precedence over values defined on the client or passed to this method.
210
269
extra_headers : Headers | None = None ,
@@ -337,6 +396,7 @@ async def watch(
337
396
* ,
338
397
environment_id : str ,
339
398
connect_protocol_version : Literal [1 ],
399
+ organization : bool | NotGiven = NOT_GIVEN ,
340
400
connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
341
401
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
342
402
# The extra values given here take precedence over values defined on the client or passed to this method.
@@ -356,6 +416,11 @@ async def watch(
356
416
357
417
connect_protocol_version: Define the version of the Connect protocol
358
418
419
+ organization: Organization scope produces events for all projects, runners and environments
420
+
421
+ the caller can see within their organization. No task, task execution or service
422
+ events are produed.
423
+
359
424
connect_timeout_ms: Define the timeout, in ms
360
425
361
426
extra_headers: Send extra headers
@@ -374,6 +439,7 @@ async def watch(
374
439
* ,
375
440
organization : bool ,
376
441
connect_protocol_version : Literal [1 ],
442
+ environment_id : str | NotGiven = NOT_GIVEN ,
377
443
connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
378
444
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
379
445
# The extra values given here take precedence over values defined on the client or passed to this method.
@@ -393,6 +459,11 @@ async def watch(
393
459
394
460
connect_protocol_version: Define the version of the Connect protocol
395
461
462
+ environment_id: Environment scope produces events for the environment itself, all tasks, task
463
+ executions,
464
+
465
+ and services associated with that environment.
466
+
396
467
connect_timeout_ms: Define the timeout, in ms
397
468
398
469
extra_headers: Send extra headers
@@ -405,14 +476,61 @@ async def watch(
405
476
"""
406
477
...
407
478
408
- @required_args ([ "environment_id" , "connect_protocol_version" ], [ "organization" , "connect_protocol_version" ])
479
+ @overload
409
480
async def watch (
410
481
self ,
411
482
* ,
412
- environment_id : str | NotGiven = NOT_GIVEN ,
413
483
connect_protocol_version : Literal [1 ],
484
+ environment_id : str | NotGiven = NOT_GIVEN ,
485
+ organization : bool | NotGiven = NOT_GIVEN ,
414
486
connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
487
+ # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
488
+ # The extra values given here take precedence over values defined on the client or passed to this method.
489
+ extra_headers : Headers | None = None ,
490
+ extra_query : Query | None = None ,
491
+ extra_body : Body | None = None ,
492
+ timeout : float | httpx .Timeout | None | NotGiven = NOT_GIVEN ,
493
+ ) -> EventWatchResponse :
494
+ """
495
+ WatchEvents streams all requests events to the client
496
+
497
+ Args:
498
+ connect_protocol_version: Define the version of the Connect protocol
499
+
500
+ environment_id: Environment scope produces events for the environment itself, all tasks, task
501
+ executions,
502
+
503
+ and services associated with that environment.
504
+
505
+ organization: Organization scope produces events for all projects, runners and environments
506
+
507
+ the caller can see within their organization. No task, task execution or service
508
+ events are produed.
509
+
510
+ connect_timeout_ms: Define the timeout, in ms
511
+
512
+ extra_headers: Send extra headers
513
+
514
+ extra_query: Add additional query parameters to the request
515
+
516
+ extra_body: Add additional JSON properties to the request
517
+
518
+ timeout: Override the client-level default timeout for this request, in seconds
519
+ """
520
+ ...
521
+
522
+ @required_args (
523
+ ["environment_id" , "connect_protocol_version" ],
524
+ ["organization" , "connect_protocol_version" ],
525
+ ["connect_protocol_version" ],
526
+ )
527
+ async def watch (
528
+ self ,
529
+ * ,
530
+ environment_id : str | NotGiven = NOT_GIVEN ,
531
+ connect_protocol_version : Literal [1 ],
415
532
organization : bool | NotGiven = NOT_GIVEN ,
533
+ connect_timeout_ms : float | NotGiven = NOT_GIVEN ,
416
534
# Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
417
535
# The extra values given here take precedence over values defined on the client or passed to this method.
418
536
extra_headers : Headers | None = None ,
0 commit comments