_jSSKJr SSKJrJrJr SSKJr SSKrSSK J r J r J r J r SSKJrJrJrJrJrJrJrJr SSKJrJrJr SS KJr SS KJrJr SS K J!r!J"r"J#r#J$r$ SS K%J&r& SS K'J(r( SSK)J*r* SSK+J,r, SSK-J.r. SSK/J0r0 SS/r1"SS\5r2"SS\5r3"SS5r4"SS5r5"SS5r6"SS5r7g)) annotations)DictListOptional)LiteralN)monitor_list_paramsmonitor_create_paramsmonitor_events_paramsmonitor_update_params)BodyOmitQueryHeadersNoneTypeNotGivenomit not_given) path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)make_request_options)Monitor)MonitorWebhookParam)PaginatedMonitorEvents)PaginatedMonitorResponse)%UpdateMonitorEventStreamSettingsParamMonitorResourceAsyncMonitorResourcec \rSrSrSr\SSj5r\SSj5r\\\SSS\ S.SSjjr SSS\ S.SS jjr \\\\\SSS\ S . SS jjr \\\\SSS\ S .SS jjr SSS\ S.SSjjr\\\\SSS\ S.SSjjrSSS\ S.SSjjrSrg)r%$The Monitor API watches the web for material changes on a fixed frequency. Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. - `event_stream` monitors track a search query and emit an event for each new material change. - `snapshot` monitors track a specific task run's output and emit an event when the output changes. Results can be polled via the events endpoint or delivered via webhooks. c[U5$z This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. For more information, see https://www.github.com/parallel-web/parallel-sdk-python#accessing-raw-response-data-eg-headers )MonitorResourceWithRawResponseselfs O/home/rurouni/.local/lib/python3.13/site-packages/parallel/resources/monitor.pywith_raw_response!MonitorResource.with_raw_response.s.d33c[U5$z An alternative to `.with_raw_response` that doesn't eagerly read the response body. For more information, see https://www.github.com/parallel-web/parallel-sdk-python#with_streaming_response )$MonitorResourceWithStreamingResponser-s r/with_streaming_response'MonitorResource.with_streaming_response8s4D99r2Nmetadata processorwebhook extra_headers extra_query extra_bodytimeoutc |URS[UUUUUUS.[R5[ XxXS9[ S9$)M Create a monitor. Monitors run on a fixed frequency to detect material changes in web content. Set `type=event_stream` to monitor a search query, or `type=snapshot` to monitor a specific task run's output. The monitor runs once immediately at creation, then continues on the configured schedule. Args: frequency: Frequency of the monitor. Format: '' where unit is 'h' (hours), 'd' (days), or 'w' (weeks). Must be between 1h and 30d (inclusive). settings: Type-specific settings for the monitor. The expected shape is determined by the root `type` field: pass `MonitorEventStreamSettings` when `type` is `event_stream`, and `MonitorSnapshotSettings` when `type` is `snapshot`. type: Type of monitor to create. `event_stream` monitors a search query for material changes; `snapshot` monitors a specific task run's output. Determines the expected shape of `settings`. metadata: User-provided metadata stored with the monitor and echoed back in webhook notifications and GET responses, so you can map events to objects in your application. Keys: max 16 chars; values: max 512 chars. processor: Processor to use for the monitor. `lite` is faster and cheaper; `base` performs more thorough analysis at higher cost and latency. Defaults to `lite`. webhook: Webhook configuration for a monitor. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds /v1/monitors frequencysettingstyper9r:r;r<r=r>r?bodyoptionscast_to)_postrr MonitorCreateParamsrr r.rDrErFr9r:r;r<r=r>r?s r/createMonitorResource.createAs]jzz  !* ( (!*& &99 )+Q[!  r2rGc xU(d[SU<35eUR[SUS9[X#XES9[S9$)Retrieve a monitor. Retrieves a specific monitor by `monitor_id`. Returns the monitor configuration including status, frequency, query, and webhook settings. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds 9Expected a non-empty value for `monitor_id` but received /v1/monitors/{monitor_id} monitor_idrGrJrK ValueError_getrrr r.rVr<r=r>r?s r/retrieveMonitorResource.retrievesP6XYcXfgh hyy 5* M(+Q[   r2 rDr9rErFr;r<r=r>r?c U(d[SU<35eUR[SUS9[UUUUUS.[R 5[ XxXS9[S9$) Update a monitor. Only fields explicitly included in the request body are changed. Pass `null` for `webhook` or `metadata` to clear those fields. Pass `type` and `settings` to update type-specific settings on an `event_stream` monitor. At least one field must be provided. Cancelled monitors cannot be updated. Args: frequency: Frequency of the monitor. Format: '' where unit is 'h' (hours), 'd' (days), or 'w' (weeks). Must be between 1h and 30d (inclusive). metadata: User-provided metadata stored with the monitor and echoed back in webhook notifications and GET responses, so you can map events to objects in your application. Keys: max 16 chars; values: max 512 chars. settings: Type-specific update settings for an `event_stream` monitor. type: Type of the monitor being updated. Required when `settings` is provided; must be `event_stream` (snapshot monitors have no updatable type-specific settings). webhook: Webhook configuration for a monitor. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rS /v1/monitors/{monitor_id}/updaterUrDr9rErFr;rGrH)rYrLrrr MonitorUpdateParamsrr r.rVrDr9rErFr;r<r=r>r?s r/updateMonitorResource.updatesz^XYcXfgh hzz < T !* ( ( & &99 )+Q[  r2cursorlimitstatusrFr<r=r>r?c|URS[UUUU[UUUUS.[R5S9[ S9$) List monitors ordered by creation time, newest first. Monitors are sorted by `created_at` descending. `limit` defaults to 100. Use `next_cursor` from the response and pass it as `cursor` to fetch the next page. Pagination ends when `next_cursor` is absent. By default only `active` monitors are returned. Pass `status=cancelled` or both values to include cancelled monitors. The legacy Monitor API (`/v1alpha/monitors` endpoints) is documented under the `Monitor (Alpha)` tag. Args: cursor: Pagination token from `next_cursor` in a previous response. Omit to start from the most recently created monitor. limit: Maximum number of monitors to return. Defaults to 100. Between 1 and 10000. status: Filter by monitor status. Pass multiple times to filter by multiple values. Defaults to `active` only. type: Filter by monitor type. Pass multiple times to filter by multiple values. Omit to return all types. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rBrhrirjrFr<r=r>r?queryrW)rZrrr MonitorListParamsr# r.rhrirjrFr<r=r>r?s r/listMonitorResource.lists[^yy (+'%%"(!&"( $  (99 -#  r2c xU(d[SU<35eUR[SUS9[X#XES9[S9$)Cancel a monitor. Permanently stops the monitor from running. Cancellation is irreversible — create a new monitor to resume monitoring. Cancelling an already-cancelled monitor is a no-op. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rS /v1/monitors/{monitor_id}/cancelrUrGrWrYrLrrr r[s r/cancelMonitorResource.cancel4sP8XYcXfgh hzz < T(+Q[   r2rhevent_group_idinclude_completionsrir<r=r>r?cU(d[SU<35eUR[SUS9[UUUU [ UUUUS.[ R 5S9[S9$) List events for a monitor, newest first. Pass `event_group_id` to narrow results to a single execution. Otherwise returns all executions newest-first; use `next_cursor` to paginate. Set `include_completions=true` to also include no-change executions. Args: cursor: Pass `next_cursor` from a previous response to retrieve more events. event_group_id: Filter to a single execution. Values come from `event_group_id` in webhook events and listed events. Pagination params are ignored when set. include_completions: When true, include completion events for executions that ran but detected no material changes. Useful for auditing execution history. limit: Maximum number of events to return. Defaults to 20. Between 1 and 100. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rS /v1/monitors/{monitor_id}/eventsrUrhr{r|rirnrW)rYrZrrrr MonitorEventsParamsr" r.rVrhr{r|rir<r=r>r?s r/eventsMonitorResource.eventsZs{RXYcXfgh hyy < T(+'%%"(*8/B!&  *== +#  r2c U(d[SU<35eSS0U=(d 0EnUR[SUS9[X#XES9[S9$) Trigger an immediate monitor run. Enqueues a one-off execution of the monitor outside its normal schedule. The monitor's regular schedule is not affected. An event is only emitted if the execution detects a material change. Cancelled monitors cannot be triggered. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rSAccept*/*!/v1/monitors/{monitor_id}/triggerrUrGrWrYrLrrrr[s r/triggerMonitorResource.triggersd6XYcXfgh h!5B]-@bB zz =* U(+Q[   r2)returnr,)rr5rDstrrEzmonitor_create_params.SettingsrFz#Literal['event_stream', 'snapshot']r9Optional[Dict[str, str]] | Omitr:zLiteral['lite', 'base'] | Omitr;$Optional[MonitorWebhookParam] | Omitr<Headers | Noner= Query | Noner> Body | Noner?'float | httpx.Timeout | None | NotGivenrr rVrr<rr=rr>rr?rrr rVrrDOptional[str] | Omitr9rrEz6Optional[UpdateMonitorEventStreamSettingsParam] | OmitrFz4Optional[Literal['event_stream', 'snapshot']] | Omitr;rr<rr=rr>rr?rrr rhrriOptional[int] | Omitrjz5Optional[List[Literal['active', 'cancelled']]] | OmitrFz:Optional[List[Literal['event_stream', 'snapshot']]] | Omitr<rr=rr>rr?rrr#rVrrhrr{rr|z bool | Omitrirr<rr=rr>rr?rrr" rVrr<rr=rr>rr?rrNone__name__ __module__ __qualname____firstlineno____doc__rr0r6rrrOr\rerrrxrr__static_attributes__rr2r/r%r%$sa44::59488<)-$("&;DF F 1 F 2 F 2 F 2F 6F &F "F  F 9F  F \)-$("&;D# # & # "#  # 9#  # R+/48KOEI8<)-$("&;DA A ( A 2 A I A CA 6A &A "A  A 9A  A L(,&*HLKO)-$("&;DA %A $ A F A I A &A "A  A 9A  "A R)-$("&;D$ $ & $ "$  $ 9$  $ T(,/3+/&*)-$("&;D= = % = - = ) = $= &= "=  = 9=  = J)-$("&;D$ $ & $ "$  $ 9$  $ $ r2c \rSrSrSr\SSj5r\SSj5r\\\SSS\ S.SSjjr SSS\ S.SS jjr \\\\\SSS\ S . SS jjr \\\\SSS\ S .SS jjr SSS\ S.SSjjr\\\\SSS\ S.SSjjrSSS\ S.SSjjrSrg)r&ir)c[U5$r+)#AsyncMonitorResourceWithRawResponser-s r/r0&AsyncMonitorResource.with_raw_responses3488r2c[U5$r4))AsyncMonitorResourceWithStreamingResponser-s r/r6,AsyncMonitorResource.with_streaming_responses9>>r2Nr8c # URS[UUUUUUS.[R5IShvN [ XxXS9[ S9IShvN $NN7f)rArBrCNrGrH)rLrr rMrr rNs r/rOAsyncMonitorResource.createstjZZ ,!* ( (!*& &99  )+Q[!      s!1AA A A AArGc # U(d[SU<35eUR[SUS9[X#XES9[S9IShvN $N7f)rRrSrTrUrGrWNrXr[s r/r\AsyncMonitorResource.retrieve%s]6XYcXfgh hYY 5* M(+Q[     ?AAAr^c # U(d[SU<35eUR[SUS9[UUUUUS.[R 5IShvN [ XxXS9[S9IShvN $NN7f)r`rSrarUrbNrGrH)rYrLrrr rcrr rds r/reAsyncMonitorResource.updateJs^XYcXfgh hZZ < T,!* ( ( & &99  )+Q[      s$AA1A- A1(A/)A1/A1rgc# URS[UUUU[UUUUS.[R5IShvN S9[ S9IShvN $NN7f)rlrBrmNrnrW)rZrrr rpr#rqs r/rrAsyncMonitorResource.listsr^YY (+'%1"(!&"( $  (99 -#    s!8AAA A AAc # U(d[SU<35eUR[SUS9[X#XES9[S9IShvN $N7f)rurSrvrUrGrWNrwr[s r/rxAsyncMonitorResource.cancels]8XYcXfgh hZZ < T(+Q[      rrzc# U(d[SU<35eUR[SUS9[UUUU [ UUUUS.[ R 5IShvN S9[S9IShvN $NN7f)r~rSrrUrNrnrW)rYrZrrrr rr"rs r/rAsyncMonitorResource.eventssRXYcXfgh hYY < T(+'%1"(*8/B!&  *== +#    s$AA2A.A2)A0*A20A2c # U(d[SU<35eSS0U=(d 0EnUR[SUS9[X#XES9[S9IShvN $N7f) rrSrrrrUrGrWNrr[s r/rAsyncMonitorResource.trigger5sq6XYcXfgh h!5B]-@bB ZZ =* U(+Q[      sAAAAr)rr)rrrrrrrrrrr2r/r&r&sa99??59488<)-$("&;DF F 1 F 2 F 2 F 2F 6F &F "F  F 9F  F \)-$("&;D# # & # "#  # 9#  # R+/48KOEI8<)-$("&;DA A ( A 2 A I A CA 6A &A "A  A 9A  A L(,&*HLKO)-$("&;DA %A $ A F A I A &A "A  A 9A  "A R)-$("&;D$ $ & $ "$  $ 9$  $ T(,/3+/&*)-$("&;D= = % = - = ) = $= &= "=  = 9=  = J)-$("&;D$ $ & $ "$  $ 9$  $ $ r2c\rSrSrSSjrSrg)r,i\c|Xl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ul[UR5UlgN) _monitorrrOr\rerrrxrrr.monitors r/__init__'MonitorResourceWithRawResponse.__init__]s - NN  0     . NN  , LL  . NN  . NN  / OO  r2rrxrOrrrr\rreNrr%rrrrrrrrrr2r/r,r,\ r2r,c\rSrSrSSjrSrg)riwc|Xl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ul[UR5Ulgr) rrrOr\rerrrxrrrs r/r,AsyncMonitorResourceWithRawResponse.__init__xs 3 NN  6     4 NN  2 LL  4 NN  4 NN  5 OO  r2rNrr&rrrrr2r/rrwrr2rc\rSrSrSSjrSrg)r5ic|Xl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ul[UR5Ulgr) rrrOr\rerrrxrrrs r/r-MonitorResourceWithStreamingResponse.__init__s 2 NN  5     3 NN  1 LL  3 NN  3 NN  4 OO  r2rNrrrr2r/r5r5rr2r5c\rSrSrSSjrSrg)ric|Xl[UR5Ul[UR5Ul[UR5Ul[UR 5Ul[UR 5Ul[UR5Ul[UR5Ulgr) rrrOr\rerrrxrrrs r/r2AsyncMonitorResourceWithStreamingResponse.__init__s 8 NN  ;     9 NN  7 LL  9 NN  9 NN  : OO  r2rNrrrr2r/rrrr2r)8 __future__rtypingrrrtyping_extensionsrhttpxtypesr r r r _typesr rrrrrrr_utilsrrr_compatr _resourcerr _responserrrr _base_clientr types.monitorr types.monitor_webhook_paramr!types.paginated_monitor_eventsr" types.paginated_monitor_responser#0types.update_monitor_event_stream_settings_paramr$__all__r%r&r,rr5rrr2r/rs#''%  UTTJJ%9 0#=CGd 4 5Y oY x Y +Y x   6  6  6  r2