|
54 | 54 | from .types.advanced_extract_settings_param import AdvancedExtractSettingsParam |
55 | 55 |
|
56 | 56 | if TYPE_CHECKING: |
57 | | - from .resources import beta, task_run, task_group |
| 57 | + from .resources import beta, monitor, task_run, task_group |
| 58 | + from .resources.monitor import MonitorResource, AsyncMonitorResource |
58 | 59 | from .resources.task_run import TaskRunResource, AsyncTaskRunResource |
59 | 60 | from .resources.beta.beta import BetaResource, AsyncBetaResource |
60 | 61 | from .resources.task_group import TaskGroupResource, AsyncTaskGroupResource |
@@ -171,6 +172,20 @@ def task_group(self) -> TaskGroupResource: |
171 | 172 |
|
172 | 173 | return TaskGroupResource(self) |
173 | 174 |
|
| 175 | + @cached_property |
| 176 | + def monitor(self) -> MonitorResource: |
| 177 | + """The Monitor API watches the web for material changes on a fixed frequency. |
| 178 | +
|
| 179 | + Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. |
| 180 | + - `event_stream` monitors track a search query and emit an event for each new material change. |
| 181 | + - `snapshot` monitors track a specific task run's output and emit an event when the output changes. |
| 182 | +
|
| 183 | + Results can be polled via the events endpoint or delivered via webhooks. |
| 184 | + """ |
| 185 | + from .resources.monitor import MonitorResource |
| 186 | + |
| 187 | + return MonitorResource(self) |
| 188 | + |
174 | 189 | @cached_property |
175 | 190 | def beta(self) -> BetaResource: |
176 | 191 | from .resources.beta import BetaResource |
@@ -549,6 +564,20 @@ def task_group(self) -> AsyncTaskGroupResource: |
549 | 564 |
|
550 | 565 | return AsyncTaskGroupResource(self) |
551 | 566 |
|
| 567 | + @cached_property |
| 568 | + def monitor(self) -> AsyncMonitorResource: |
| 569 | + """The Monitor API watches the web for material changes on a fixed frequency. |
| 570 | +
|
| 571 | + Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. |
| 572 | + - `event_stream` monitors track a search query and emit an event for each new material change. |
| 573 | + - `snapshot` monitors track a specific task run's output and emit an event when the output changes. |
| 574 | +
|
| 575 | + Results can be polled via the events endpoint or delivered via webhooks. |
| 576 | + """ |
| 577 | + from .resources.monitor import AsyncMonitorResource |
| 578 | + |
| 579 | + return AsyncMonitorResource(self) |
| 580 | + |
552 | 581 | @cached_property |
553 | 582 | def beta(self) -> AsyncBetaResource: |
554 | 583 | from .resources.beta import AsyncBetaResource |
@@ -876,6 +905,20 @@ def task_group(self) -> task_group.TaskGroupResourceWithRawResponse: |
876 | 905 |
|
877 | 906 | return TaskGroupResourceWithRawResponse(self._client.task_group) |
878 | 907 |
|
| 908 | + @cached_property |
| 909 | + def monitor(self) -> monitor.MonitorResourceWithRawResponse: |
| 910 | + """The Monitor API watches the web for material changes on a fixed frequency. |
| 911 | +
|
| 912 | + Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. |
| 913 | + - `event_stream` monitors track a search query and emit an event for each new material change. |
| 914 | + - `snapshot` monitors track a specific task run's output and emit an event when the output changes. |
| 915 | +
|
| 916 | + Results can be polled via the events endpoint or delivered via webhooks. |
| 917 | + """ |
| 918 | + from .resources.monitor import MonitorResourceWithRawResponse |
| 919 | + |
| 920 | + return MonitorResourceWithRawResponse(self._client.monitor) |
| 921 | + |
879 | 922 | @cached_property |
880 | 923 | def beta(self) -> beta.BetaResourceWithRawResponse: |
881 | 924 | from .resources.beta import BetaResourceWithRawResponse |
@@ -932,6 +975,20 @@ def task_group(self) -> task_group.AsyncTaskGroupResourceWithRawResponse: |
932 | 975 |
|
933 | 976 | return AsyncTaskGroupResourceWithRawResponse(self._client.task_group) |
934 | 977 |
|
| 978 | + @cached_property |
| 979 | + def monitor(self) -> monitor.AsyncMonitorResourceWithRawResponse: |
| 980 | + """The Monitor API watches the web for material changes on a fixed frequency. |
| 981 | +
|
| 982 | + Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. |
| 983 | + - `event_stream` monitors track a search query and emit an event for each new material change. |
| 984 | + - `snapshot` monitors track a specific task run's output and emit an event when the output changes. |
| 985 | +
|
| 986 | + Results can be polled via the events endpoint or delivered via webhooks. |
| 987 | + """ |
| 988 | + from .resources.monitor import AsyncMonitorResourceWithRawResponse |
| 989 | + |
| 990 | + return AsyncMonitorResourceWithRawResponse(self._client.monitor) |
| 991 | + |
935 | 992 | @cached_property |
936 | 993 | def beta(self) -> beta.AsyncBetaResourceWithRawResponse: |
937 | 994 | from .resources.beta import AsyncBetaResourceWithRawResponse |
@@ -988,6 +1045,20 @@ def task_group(self) -> task_group.TaskGroupResourceWithStreamingResponse: |
988 | 1045 |
|
989 | 1046 | return TaskGroupResourceWithStreamingResponse(self._client.task_group) |
990 | 1047 |
|
| 1048 | + @cached_property |
| 1049 | + def monitor(self) -> monitor.MonitorResourceWithStreamingResponse: |
| 1050 | + """The Monitor API watches the web for material changes on a fixed frequency. |
| 1051 | +
|
| 1052 | + Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. |
| 1053 | + - `event_stream` monitors track a search query and emit an event for each new material change. |
| 1054 | + - `snapshot` monitors track a specific task run's output and emit an event when the output changes. |
| 1055 | +
|
| 1056 | + Results can be polled via the events endpoint or delivered via webhooks. |
| 1057 | + """ |
| 1058 | + from .resources.monitor import MonitorResourceWithStreamingResponse |
| 1059 | + |
| 1060 | + return MonitorResourceWithStreamingResponse(self._client.monitor) |
| 1061 | + |
991 | 1062 | @cached_property |
992 | 1063 | def beta(self) -> beta.BetaResourceWithStreamingResponse: |
993 | 1064 | from .resources.beta import BetaResourceWithStreamingResponse |
@@ -1044,6 +1115,20 @@ def task_group(self) -> task_group.AsyncTaskGroupResourceWithStreamingResponse: |
1044 | 1115 |
|
1045 | 1116 | return AsyncTaskGroupResourceWithStreamingResponse(self._client.task_group) |
1046 | 1117 |
|
| 1118 | + @cached_property |
| 1119 | + def monitor(self) -> monitor.AsyncMonitorResourceWithStreamingResponse: |
| 1120 | + """The Monitor API watches the web for material changes on a fixed frequency. |
| 1121 | +
|
| 1122 | + Each monitor runs once on creation and then on its configured schedule, emitting events when meaningful changes are detected. |
| 1123 | + - `event_stream` monitors track a search query and emit an event for each new material change. |
| 1124 | + - `snapshot` monitors track a specific task run's output and emit an event when the output changes. |
| 1125 | +
|
| 1126 | + Results can be polled via the events endpoint or delivered via webhooks. |
| 1127 | + """ |
| 1128 | + from .resources.monitor import AsyncMonitorResourceWithStreamingResponse |
| 1129 | + |
| 1130 | + return AsyncMonitorResourceWithStreamingResponse(self._client.monitor) |
| 1131 | + |
1047 | 1132 | @cached_property |
1048 | 1133 | def beta(self) -> beta.AsyncBetaResourceWithStreamingResponse: |
1049 | 1134 | from .resources.beta import AsyncBetaResourceWithStreamingResponse |
|
0 commit comments