|
156 | 156 | } |
157 | 157 |
|
158 | 158 | DYNAMIC_STREAM_MANIFEST = { |
159 | | - **MANIFEST, |
| 159 | + "version": "0.30.3", |
| 160 | + "definitions": { |
| 161 | + "retriever": { |
| 162 | + "paginator": { |
| 163 | + "type": "DefaultPaginator", |
| 164 | + "page_size": _page_size, |
| 165 | + "page_size_option": {"inject_into": "request_parameter", "field_name": "page_size"}, |
| 166 | + "page_token_option": {"inject_into": "path", "type": "RequestPath"}, |
| 167 | + "pagination_strategy": { |
| 168 | + "type": "CursorPagination", |
| 169 | + "cursor_value": "{{ response._metadata.next }}", |
| 170 | + "page_size": _page_size, |
| 171 | + }, |
| 172 | + }, |
| 173 | + "partition_router": { |
| 174 | + "type": "ListPartitionRouter", |
| 175 | + "values": ["0", "1", "2", "3", "4", "5", "6", "7"], |
| 176 | + "cursor_field": "item_id", |
| 177 | + }, |
| 178 | + "" "requester": { |
| 179 | + "path": "/v3/marketing/lists", |
| 180 | + "authenticator": { |
| 181 | + "type": "BearerAuthenticator", |
| 182 | + "api_token": "{{ config.apikey }}", |
| 183 | + }, |
| 184 | + "request_parameters": {"a_param": "10"}, |
| 185 | + }, |
| 186 | + "record_selector": {"extractor": {"field_path": ["result"]}}, |
| 187 | + }, |
| 188 | + }, |
| 189 | + "streams": [ |
| 190 | + { |
| 191 | + "type": "DeclarativeStream", |
| 192 | + "$parameters": _stream_options, |
| 193 | + "retriever": "#/definitions/retriever", |
| 194 | + }, |
| 195 | + ], |
| 196 | + "check": {"type": "CheckStream", "stream_names": ["lists"]}, |
| 197 | + "spec": { |
| 198 | + "connection_specification": { |
| 199 | + "$schema": "http://json-schema.org/draft-07/schema#", |
| 200 | + "type": "object", |
| 201 | + "required": [], |
| 202 | + "properties": {}, |
| 203 | + "additionalProperties": True, |
| 204 | + }, |
| 205 | + "type": "Spec", |
| 206 | + }, |
160 | 207 | "dynamic_streams": [ |
161 | 208 | { |
162 | 209 | "type": "DynamicDeclarativeStream", |
|
0 commit comments