Skip to content

Commit a1af507

Browse files
polytomic-sdk-botpolytomic-sdk-bot
committed
Release 1.4.0
1 parent 4d83331 commit a1af507

File tree

9 files changed

+216
-125
lines changed

9 files changed

+216
-125
lines changed

‎poetry.lock‎

Lines changed: 10 additions & 10 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.3.0"
3+
version = "1.4.0"
44
description = ""
55
readme = "README.md"
66
authors = []

‎src/polytomic/bulk_sync/client.py‎

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -98,6 +98,7 @@ def create(
9898
self,
9999
*,
100100
destination_connection_id: str,
101+
mode: str,
101102
name: str,
102103
schedule: BulkSchedule,
103104
source_connection_id: str,
@@ -107,7 +108,6 @@ def create(
107108
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
108109
disable_record_timestamps: typing.Optional[bool] = OMIT,
109110
discover: typing.Optional[bool] = OMIT,
110-
mode: typing.Optional[str] = OMIT,
111111
organization_id: typing.Optional[str] = OMIT,
112112
policies: typing.Optional[typing.Sequence[str]] = OMIT,
113113
schemas: typing.Optional[typing.Sequence[str]] = OMIT,
@@ -119,6 +119,9 @@ def create(
119119
----------
120120
destination_connection_id : str
121121
122+
mode : str
123+
Either 'replicate' or 'snapshot'.
124+
122125
name : str
123126
124127
schedule : BulkSchedule
@@ -138,9 +141,6 @@ def create(
138141
discover : typing.Optional[bool]
139142
DEPRECATED: Use automatically_add_new_objects/automatically_add_new_fields instead
140143
141-
mode : typing.Optional[str]
142-
143-
144144
organization_id : typing.Optional[str]
145145
146146
policies : typing.Optional[typing.Sequence[str]]
@@ -167,6 +167,7 @@ def create(
167167
)
168168
client.bulk_sync.create(
169169
destination_connection_id="248df4b7-aa70-47b8-a036-33ac447e668d",
170+
mode="replicate",
170171
name="My Bulk Sync",
171172
schedule=BulkSchedule(
172173
frequency="manual",
@@ -176,6 +177,7 @@ def create(
176177
"""
177178
_request: typing.Dict[str, typing.Any] = {
178179
"destination_connection_id": destination_connection_id,
180+
"mode": mode,
179181
"name": name,
180182
"schedule": schedule,
181183
"source_connection_id": source_connection_id,
@@ -192,8 +194,6 @@ def create(
192194
_request["disable_record_timestamps"] = disable_record_timestamps
193195
if discover is not OMIT:
194196
_request["discover"] = discover
195-
if mode is not OMIT:
196-
_request["mode"] = mode
197197
if organization_id is not OMIT:
198198
_request["organization_id"] = organization_id
199199
if policies is not OMIT:
@@ -328,6 +328,7 @@ def update(
328328
id: str,
329329
*,
330330
destination_connection_id: str,
331+
mode: str,
331332
name: str,
332333
schedule: BulkSchedule,
333334
source_connection_id: str,
@@ -337,7 +338,6 @@ def update(
337338
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
338339
disable_record_timestamps: typing.Optional[bool] = OMIT,
339340
discover: typing.Optional[bool] = OMIT,
340-
mode: typing.Optional[str] = OMIT,
341341
organization_id: typing.Optional[str] = OMIT,
342342
policies: typing.Optional[typing.Sequence[str]] = OMIT,
343343
schemas: typing.Optional[typing.Sequence[str]] = OMIT,
@@ -355,6 +355,9 @@ def update(
355355
356356
destination_connection_id : str
357357
358+
mode : str
359+
Either 'replicate' or 'snapshot'.
360+
358361
name : str
359362
360363
schedule : BulkSchedule
@@ -374,9 +377,6 @@ def update(
374377
discover : typing.Optional[bool]
375378
DEPRECATED: Use automatically_add_new_objects/automatically_add_new_fields instead
376379
377-
mode : typing.Optional[str]
378-
379-
380380
organization_id : typing.Optional[str]
381381
382382
policies : typing.Optional[typing.Sequence[str]]
@@ -404,6 +404,7 @@ def update(
404404
client.bulk_sync.update(
405405
id="248df4b7-aa70-47b8-a036-33ac447e668d",
406406
destination_connection_id="248df4b7-aa70-47b8-a036-33ac447e668d",
407+
mode="replicate",
407408
name="My Bulk Sync",
408409
schedule=BulkSchedule(
409410
frequency="manual",
@@ -413,6 +414,7 @@ def update(
413414
"""
414415
_request: typing.Dict[str, typing.Any] = {
415416
"destination_connection_id": destination_connection_id,
417+
"mode": mode,
416418
"name": name,
417419
"schedule": schedule,
418420
"source_connection_id": source_connection_id,
@@ -429,8 +431,6 @@ def update(
429431
_request["disable_record_timestamps"] = disable_record_timestamps
430432
if discover is not OMIT:
431433
_request["discover"] = discover
432-
if mode is not OMIT:
433-
_request["mode"] = mode
434434
if organization_id is not OMIT:
435435
_request["organization_id"] = organization_id
436436
if policies is not OMIT:
@@ -1011,6 +1011,7 @@ async def create(
10111011
self,
10121012
*,
10131013
destination_connection_id: str,
1014+
mode: str,
10141015
name: str,
10151016
schedule: BulkSchedule,
10161017
source_connection_id: str,
@@ -1020,7 +1021,6 @@ async def create(
10201021
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
10211022
disable_record_timestamps: typing.Optional[bool] = OMIT,
10221023
discover: typing.Optional[bool] = OMIT,
1023-
mode: typing.Optional[str] = OMIT,
10241024
organization_id: typing.Optional[str] = OMIT,
10251025
policies: typing.Optional[typing.Sequence[str]] = OMIT,
10261026
schemas: typing.Optional[typing.Sequence[str]] = OMIT,
@@ -1032,6 +1032,9 @@ async def create(
10321032
----------
10331033
destination_connection_id : str
10341034
1035+
mode : str
1036+
Either 'replicate' or 'snapshot'.
1037+
10351038
name : str
10361039
10371040
schedule : BulkSchedule
@@ -1051,9 +1054,6 @@ async def create(
10511054
discover : typing.Optional[bool]
10521055
DEPRECATED: Use automatically_add_new_objects/automatically_add_new_fields instead
10531056
1054-
mode : typing.Optional[str]
1055-
1056-
10571057
organization_id : typing.Optional[str]
10581058
10591059
policies : typing.Optional[typing.Sequence[str]]
@@ -1080,6 +1080,7 @@ async def create(
10801080
)
10811081
await client.bulk_sync.create(
10821082
destination_connection_id="248df4b7-aa70-47b8-a036-33ac447e668d",
1083+
mode="replicate",
10831084
name="My Bulk Sync",
10841085
schedule=BulkSchedule(
10851086
frequency="manual",
@@ -1089,6 +1090,7 @@ async def create(
10891090
"""
10901091
_request: typing.Dict[str, typing.Any] = {
10911092
"destination_connection_id": destination_connection_id,
1093+
"mode": mode,
10921094
"name": name,
10931095
"schedule": schedule,
10941096
"source_connection_id": source_connection_id,
@@ -1105,8 +1107,6 @@ async def create(
11051107
_request["disable_record_timestamps"] = disable_record_timestamps
11061108
if discover is not OMIT:
11071109
_request["discover"] = discover
1108-
if mode is not OMIT:
1109-
_request["mode"] = mode
11101110
if organization_id is not OMIT:
11111111
_request["organization_id"] = organization_id
11121112
if policies is not OMIT:
@@ -1241,6 +1241,7 @@ async def update(
12411241
id: str,
12421242
*,
12431243
destination_connection_id: str,
1244+
mode: str,
12441245
name: str,
12451246
schedule: BulkSchedule,
12461247
source_connection_id: str,
@@ -1250,7 +1251,6 @@ async def update(
12501251
destination_configuration: typing.Optional[typing.Dict[str, typing.Any]] = OMIT,
12511252
disable_record_timestamps: typing.Optional[bool] = OMIT,
12521253
discover: typing.Optional[bool] = OMIT,
1253-
mode: typing.Optional[str] = OMIT,
12541254
organization_id: typing.Optional[str] = OMIT,
12551255
policies: typing.Optional[typing.Sequence[str]] = OMIT,
12561256
schemas: typing.Optional[typing.Sequence[str]] = OMIT,
@@ -1268,6 +1268,9 @@ async def update(
12681268
12691269
destination_connection_id : str
12701270
1271+
mode : str
1272+
Either 'replicate' or 'snapshot'.
1273+
12711274
name : str
12721275
12731276
schedule : BulkSchedule
@@ -1287,9 +1290,6 @@ async def update(
12871290
discover : typing.Optional[bool]
12881291
DEPRECATED: Use automatically_add_new_objects/automatically_add_new_fields instead
12891292
1290-
mode : typing.Optional[str]
1291-
1292-
12931293
organization_id : typing.Optional[str]
12941294
12951295
policies : typing.Optional[typing.Sequence[str]]
@@ -1317,6 +1317,7 @@ async def update(
13171317
await client.bulk_sync.update(
13181318
id="248df4b7-aa70-47b8-a036-33ac447e668d",
13191319
destination_connection_id="248df4b7-aa70-47b8-a036-33ac447e668d",
1320+
mode="replicate",
13201321
name="My Bulk Sync",
13211322
schedule=BulkSchedule(
13221323
frequency="manual",
@@ -1326,6 +1327,7 @@ async def update(
13261327
"""
13271328
_request: typing.Dict[str, typing.Any] = {
13281329
"destination_connection_id": destination_connection_id,
1330+
"mode": mode,
13291331
"name": name,
13301332
"schedule": schedule,
13311333
"source_connection_id": source_connection_id,
@@ -1342,8 +1344,6 @@ async def update(
13421344
_request["disable_record_timestamps"] = disable_record_timestamps
13431345
if discover is not OMIT:
13441346
_request["discover"] = discover
1345-
if mode is not OMIT:
1346-
_request["mode"] = mode
13471347
if organization_id is not OMIT:
13481348
_request["organization_id"] = organization_id
13491349
if policies is not OMIT:

0 commit comments

Comments
 (0)