Skip to content

Commit 38848f4

Browse files
Release 1.10.1
1 parent 3d8e23d commit 38848f4

21 files changed

+325
-128
lines changed

poetry.lock

Lines changed: 124 additions & 116 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

pyproject.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
[tool.poetry]
22
name = "polytomic"
3-
version = "1.9.3"
3+
version = "1.10.1"
44
description = ""
55
readme = "README.md"
66
authors = []

reference.md

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -156,6 +156,14 @@ client.bulk_sync.create(
156156
<dl>
157157
<dd>
158158

159+
**data_cutoff_timestamp:** `typing.Optional[dt.datetime]`
160+
161+
</dd>
162+
</dl>
163+
164+
<dl>
165+
<dd>
166+
159167
**destination_configuration:** `typing.Optional[typing.Dict[str, typing.Any]]`
160168

161169
</dd>
@@ -422,6 +430,14 @@ client.bulk_sync.update(
422430
<dl>
423431
<dd>
424432

433+
**data_cutoff_timestamp:** `typing.Optional[dt.datetime]`
434+
435+
</dd>
436+
</dl>
437+
438+
<dl>
439+
<dd>
440+
425441
**destination_configuration:** `typing.Optional[typing.Dict[str, typing.Any]]`
426442

427443
</dd>
@@ -1480,6 +1496,22 @@ client.bulk_sync.schemas.update(
14801496
<dl>
14811497
<dd>
14821498

1499+
**data_cutoff_timestamp:** `typing.Optional[dt.datetime]`
1500+
1501+
</dd>
1502+
</dl>
1503+
1504+
<dl>
1505+
<dd>
1506+
1507+
**disable_data_cutoff:** `typing.Optional[bool]`
1508+
1509+
</dd>
1510+
</dl>
1511+
1512+
<dl>
1513+
<dd>
1514+
14831515
**enabled:** `typing.Optional[bool]`
14841516

14851517
</dd>
@@ -3258,6 +3290,14 @@ client.model_sync.get_source_fields(
32583290
<dl>
32593291
<dd>
32603292

3293+
**params:** `typing.Optional[typing.Dict[str, typing.Optional[typing.Sequence[str]]]]`
3294+
3295+
</dd>
3296+
</dl>
3297+
3298+
<dl>
3299+
<dd>
3300+
32613301
**request_options:** `typing.Optional[RequestOptions]` — Request-specific configuration.
32623302

32633303
</dd>

src/polytomic/__init__.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@
4040
BulkSyncSourceStatusEnvelope,
4141
BulkSyncStatusEnvelope,
4242
BulkSyncStatusResponse,
43+
CommonOutputActor,
4344
ConfigurationValue,
4445
ConnectCardResponse,
4546
ConnectCardResponseEnvelope,
@@ -176,6 +177,7 @@
176177
)
177178
from .errors import (
178179
BadRequestError,
180+
ConflictError,
179181
ForbiddenError,
180182
InternalServerError,
181183
NotFoundError,
@@ -242,7 +244,9 @@
242244
"BulkSyncSourceStatusEnvelope",
243245
"BulkSyncStatusEnvelope",
244246
"BulkSyncStatusResponse",
247+
"CommonOutputActor",
245248
"ConfigurationValue",
249+
"ConflictError",
246250
"ConnectCardResponse",
247251
"ConnectCardResponseEnvelope",
248252
"ConnectionListResponseEnvelope",

src/polytomic/bulk_sync/client.py

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
# This file was auto-generated from our API Definition.
22

3+
import datetime as dt
34
import typing
45
from json.decoder import JSONDecodeError
56

@@ -96,6 +97,7 @@ def create(
9697
active: typing.Optional[bool] = OMIT,
9798
automatically_add_new_fields: typing.Optional[BulkDiscover] = OMIT,
9899
automatically_add_new_objects: typing.Optional[BulkDiscover] = OMIT,
100+
data_cutoff_timestamp: typing.Optional[dt.datetime] = OMIT,
99101
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
100102
disable_record_timestamps: typing.Optional[bool] = OMIT,
101103
discover: typing.Optional[bool] = OMIT,
@@ -123,6 +125,8 @@ def create(
123125
124126
automatically_add_new_objects : typing.Optional[BulkDiscover]
125127
128+
data_cutoff_timestamp : typing.Optional[dt.datetime]
129+
126130
destination_configuration : typing.Optional[typing.Dict[str, typing.Any]]
127131
128132
disable_record_timestamps : typing.Optional[bool]
@@ -174,6 +178,7 @@ def create(
174178
"active": active,
175179
"automatically_add_new_fields": automatically_add_new_fields,
176180
"automatically_add_new_objects": automatically_add_new_objects,
181+
"data_cutoff_timestamp": data_cutoff_timestamp,
177182
"destination_configuration": destination_configuration,
178183
"destination_connection_id": destination_connection_id,
179184
"disable_record_timestamps": disable_record_timestamps,
@@ -282,6 +287,7 @@ def update(
282287
active: typing.Optional[bool] = OMIT,
283288
automatically_add_new_fields: typing.Optional[BulkDiscover] = OMIT,
284289
automatically_add_new_objects: typing.Optional[BulkDiscover] = OMIT,
290+
data_cutoff_timestamp: typing.Optional[dt.datetime] = OMIT,
285291
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
286292
disable_record_timestamps: typing.Optional[bool] = OMIT,
287293
discover: typing.Optional[bool] = OMIT,
@@ -315,6 +321,8 @@ def update(
315321
316322
automatically_add_new_objects : typing.Optional[BulkDiscover]
317323
324+
data_cutoff_timestamp : typing.Optional[dt.datetime]
325+
318326
destination_configuration : typing.Optional[typing.Dict[str, typing.Any]]
319327
320328
disable_record_timestamps : typing.Optional[bool]
@@ -367,6 +375,7 @@ def update(
367375
"active": active,
368376
"automatically_add_new_fields": automatically_add_new_fields,
369377
"automatically_add_new_objects": automatically_add_new_objects,
378+
"data_cutoff_timestamp": data_cutoff_timestamp,
370379
"destination_configuration": destination_configuration,
371380
"destination_connection_id": destination_connection_id,
372381
"disable_record_timestamps": disable_record_timestamps,
@@ -825,6 +834,7 @@ async def create(
825834
active: typing.Optional[bool] = OMIT,
826835
automatically_add_new_fields: typing.Optional[BulkDiscover] = OMIT,
827836
automatically_add_new_objects: typing.Optional[BulkDiscover] = OMIT,
837+
data_cutoff_timestamp: typing.Optional[dt.datetime] = OMIT,
828838
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
829839
disable_record_timestamps: typing.Optional[bool] = OMIT,
830840
discover: typing.Optional[bool] = OMIT,
@@ -852,6 +862,8 @@ async def create(
852862
853863
automatically_add_new_objects : typing.Optional[BulkDiscover]
854864
865+
data_cutoff_timestamp : typing.Optional[dt.datetime]
866+
855867
destination_configuration : typing.Optional[typing.Dict[str, typing.Any]]
856868
857869
disable_record_timestamps : typing.Optional[bool]
@@ -911,6 +923,7 @@ async def main() -> None:
911923
"active": active,
912924
"automatically_add_new_fields": automatically_add_new_fields,
913925
"automatically_add_new_objects": automatically_add_new_objects,
926+
"data_cutoff_timestamp": data_cutoff_timestamp,
914927
"destination_configuration": destination_configuration,
915928
"destination_connection_id": destination_connection_id,
916929
"disable_record_timestamps": disable_record_timestamps,
@@ -1027,6 +1040,7 @@ async def update(
10271040
active: typing.Optional[bool] = OMIT,
10281041
automatically_add_new_fields: typing.Optional[BulkDiscover] = OMIT,
10291042
automatically_add_new_objects: typing.Optional[BulkDiscover] = OMIT,
1043+
data_cutoff_timestamp: typing.Optional[dt.datetime] = OMIT,
10301044
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
10311045
disable_record_timestamps: typing.Optional[bool] = OMIT,
10321046
discover: typing.Optional[bool] = OMIT,
@@ -1060,6 +1074,8 @@ async def update(
10601074
10611075
automatically_add_new_objects : typing.Optional[BulkDiscover]
10621076
1077+
data_cutoff_timestamp : typing.Optional[dt.datetime]
1078+
10631079
destination_configuration : typing.Optional[typing.Dict[str, typing.Any]]
10641080
10651081
disable_record_timestamps : typing.Optional[bool]
@@ -1120,6 +1136,7 @@ async def main() -> None:
11201136
"active": active,
11211137
"automatically_add_new_fields": automatically_add_new_fields,
11221138
"automatically_add_new_objects": automatically_add_new_objects,
1139+
"data_cutoff_timestamp": data_cutoff_timestamp,
11231140
"destination_configuration": destination_configuration,
11241141
"destination_connection_id": destination_connection_id,
11251142
"disable_record_timestamps": disable_record_timestamps,

src/polytomic/bulk_sync/schemas/client.py

Lines changed: 29 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
# This file was auto-generated from our API Definition.
22

3+
import datetime as dt
34
import typing
45
from json.decoder import JSONDecodeError
56

@@ -205,6 +206,8 @@ def update(
205206
id: str,
206207
schema_id: str,
207208
*,
209+
data_cutoff_timestamp: typing.Optional[dt.datetime] = OMIT,
210+
disable_data_cutoff: typing.Optional[bool] = OMIT,
208211
enabled: typing.Optional[bool] = OMIT,
209212
fields: typing.Optional[typing.Sequence[BulkField]] = OMIT,
210213
filters: typing.Optional[typing.Sequence[BulkFilter]] = OMIT,
@@ -218,6 +221,10 @@ def update(
218221
219222
schema_id : str
220223
224+
data_cutoff_timestamp : typing.Optional[dt.datetime]
225+
226+
disable_data_cutoff : typing.Optional[bool]
227+
221228
enabled : typing.Optional[bool]
222229
223230
fields : typing.Optional[typing.Sequence[BulkField]]
@@ -250,7 +257,14 @@ def update(
250257
_response = self._client_wrapper.httpx_client.request(
251258
f"api/bulk/syncs/{jsonable_encoder(id)}/schemas/{jsonable_encoder(schema_id)}",
252259
method="PUT",
253-
json={"enabled": enabled, "fields": fields, "filters": filters, "partition_key": partition_key},
260+
json={
261+
"data_cutoff_timestamp": data_cutoff_timestamp,
262+
"disable_data_cutoff": disable_data_cutoff,
263+
"enabled": enabled,
264+
"fields": fields,
265+
"filters": filters,
266+
"partition_key": partition_key,
267+
},
254268
request_options=request_options,
255269
omit=OMIT,
256270
)
@@ -481,6 +495,8 @@ async def update(
481495
id: str,
482496
schema_id: str,
483497
*,
498+
data_cutoff_timestamp: typing.Optional[dt.datetime] = OMIT,
499+
disable_data_cutoff: typing.Optional[bool] = OMIT,
484500
enabled: typing.Optional[bool] = OMIT,
485501
fields: typing.Optional[typing.Sequence[BulkField]] = OMIT,
486502
filters: typing.Optional[typing.Sequence[BulkFilter]] = OMIT,
@@ -494,6 +510,10 @@ async def update(
494510
495511
schema_id : str
496512
513+
data_cutoff_timestamp : typing.Optional[dt.datetime]
514+
515+
disable_data_cutoff : typing.Optional[bool]
516+
497517
enabled : typing.Optional[bool]
498518
499519
fields : typing.Optional[typing.Sequence[BulkField]]
@@ -534,7 +554,14 @@ async def main() -> None:
534554
_response = await self._client_wrapper.httpx_client.request(
535555
f"api/bulk/syncs/{jsonable_encoder(id)}/schemas/{jsonable_encoder(schema_id)}",
536556
method="PUT",
537-
json={"enabled": enabled, "fields": fields, "filters": filters, "partition_key": partition_key},
557+
json={
558+
"data_cutoff_timestamp": data_cutoff_timestamp,
559+
"disable_data_cutoff": disable_data_cutoff,
560+
"enabled": enabled,
561+
"fields": fields,
562+
"filters": filters,
563+
"partition_key": partition_key,
564+
},
538565
request_options=request_options,
539566
omit=OMIT,
540567
)

src/polytomic/core/client_wrapper.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ def get_headers(self) -> typing.Dict[str, str]:
2525
headers: typing.Dict[str, str] = {
2626
"X-Fern-Language": "Python",
2727
"X-Fern-SDK-Name": "polytomic",
28-
"X-Fern-SDK-Version": "1.9.3",
28+
"X-Fern-SDK-Version": "1.10.1",
2929
}
3030
if self._version is not None:
3131
headers["X-Polytomic-Version"] = self._version

src/polytomic/errors/__init__.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
# This file was auto-generated by Fern from our API Definition.
22

33
from .bad_request_error import BadRequestError
4+
from .conflict_error import ConflictError
45
from .forbidden_error import ForbiddenError
56
from .internal_server_error import InternalServerError
67
from .not_found_error import NotFoundError
@@ -9,6 +10,7 @@
910

1011
__all__ = [
1112
"BadRequestError",
13+
"ConflictError",
1214
"ForbiddenError",
1315
"InternalServerError",
1416
"NotFoundError",
Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
# This file was auto-generated from our API Definition.
2+
3+
from ..core.api_error import ApiError as core_api_error_ApiError
4+
from ..types.api_error import ApiError as types_api_error_ApiError
5+
6+
7+
class ConflictError(core_api_error_ApiError):
8+
def __init__(self, body: types_api_error_ApiError):
9+
super().__init__(status_code=409, body=body)

0 commit comments

Comments
 (0)