Skip to content

Commit 5b2b1d2

Browse files
Release 1.8.0
1 parent ad27f9f commit 5b2b1d2

17 files changed

+442
-5
lines changed

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.7.0"
3+
version = "1.8.0"
44
description = ""
55
readme = "README.md"
66
authors = []

src/polytomic/__init__.py

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,14 +18,19 @@
1818
BulkSchemaEnvelope,
1919
BulkSchemaExecutionStatus,
2020
BulkSelectiveMode,
21+
BulkSyncCanceledEvent,
22+
BulkSyncCompletedEvent,
23+
BulkSyncCompletedWithErrorEvent,
2124
BulkSyncDest,
2225
BulkSyncDestEnvelope,
2326
BulkSyncExecution,
2427
BulkSyncExecutionEnvelope,
2528
BulkSyncExecutionStatus,
29+
BulkSyncFailedEvent,
2630
BulkSyncListEnvelope,
2731
BulkSyncResponse,
2832
BulkSyncResponseEnvelope,
33+
BulkSyncRunningEvent,
2934
BulkSyncSchemaExecution,
3035
BulkSyncSchemaExecutionStatus,
3136
BulkSyncSource,
@@ -54,6 +59,7 @@
5459
CreateModelRequest,
5560
Enrichment,
5661
Event,
62+
EventBody,
5763
EventTypesEnvelope,
5864
EventsEnvelope,
5965
ExecutionCounts,
@@ -130,7 +136,12 @@
130136
StartModelSyncResponseEnvelope,
131137
StartModelSyncResponseSchema,
132138
SupportedMode,
139+
SyncCanceledEvent,
140+
SyncCompletedEvent,
141+
SyncCompletedWithErrorsEvent,
133142
SyncDestinationProperties,
143+
SyncFailedEvent,
144+
SyncRunningEvent,
134145
SyncStatusEnvelope,
135146
SyncStatusResponse,
136147
Target,
@@ -198,14 +209,19 @@
198209
"BulkSchemaEnvelope",
199210
"BulkSchemaExecutionStatus",
200211
"BulkSelectiveMode",
212+
"BulkSyncCanceledEvent",
213+
"BulkSyncCompletedEvent",
214+
"BulkSyncCompletedWithErrorEvent",
201215
"BulkSyncDest",
202216
"BulkSyncDestEnvelope",
203217
"BulkSyncExecution",
204218
"BulkSyncExecutionEnvelope",
205219
"BulkSyncExecutionStatus",
220+
"BulkSyncFailedEvent",
206221
"BulkSyncListEnvelope",
207222
"BulkSyncResponse",
208223
"BulkSyncResponseEnvelope",
224+
"BulkSyncRunningEvent",
209225
"BulkSyncSchemaExecution",
210226
"BulkSyncSchemaExecutionStatus",
211227
"BulkSyncSource",
@@ -234,6 +250,7 @@
234250
"CreateModelRequest",
235251
"Enrichment",
236252
"Event",
253+
"EventBody",
237254
"EventTypesEnvelope",
238255
"EventsEnvelope",
239256
"ExecutionCounts",
@@ -314,7 +331,12 @@
314331
"StartModelSyncResponseEnvelope",
315332
"StartModelSyncResponseSchema",
316333
"SupportedMode",
334+
"SyncCanceledEvent",
335+
"SyncCompletedEvent",
336+
"SyncCompletedWithErrorsEvent",
317337
"SyncDestinationProperties",
338+
"SyncFailedEvent",
339+
"SyncRunningEvent",
318340
"SyncStatusEnvelope",
319341
"SyncStatusResponse",
320342
"Target",

src/polytomic/bulk_sync/executions/client.py

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,10 @@ def list_status(
5959
version="YOUR_VERSION",
6060
token="YOUR_TOKEN",
6161
)
62-
client.bulk_sync.executions.list_status()
62+
client.bulk_sync.executions.list_status(
63+
all_=True,
64+
active=True,
65+
)
6366
"""
6467
_response = self._client_wrapper.httpx_client.request(
6568
method="GET",
@@ -273,7 +276,10 @@ async def list_status(
273276
version="YOUR_VERSION",
274277
token="YOUR_TOKEN",
275278
)
276-
await client.bulk_sync.executions.list_status()
279+
await client.bulk_sync.executions.list_status(
280+
all_=True,
281+
active=True,
282+
)
277283
"""
278284
_response = await self._client_wrapper.httpx_client.request(
279285
method="GET",

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.7.0",
28+
"X-Fern-SDK-Version": "1.8.0",
2929
}
3030
if self._version is not None:
3131
headers["X-Polytomic-Version"] = self._version

src/polytomic/types/__init__.py

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,14 +17,19 @@
1717
from .bulk_schema_envelope import BulkSchemaEnvelope
1818
from .bulk_schema_execution_status import BulkSchemaExecutionStatus
1919
from .bulk_selective_mode import BulkSelectiveMode
20+
from .bulk_sync_canceled_event import BulkSyncCanceledEvent
21+
from .bulk_sync_completed_event import BulkSyncCompletedEvent
22+
from .bulk_sync_completed_with_error_event import BulkSyncCompletedWithErrorEvent
2023
from .bulk_sync_dest import BulkSyncDest
2124
from .bulk_sync_dest_envelope import BulkSyncDestEnvelope
2225
from .bulk_sync_execution import BulkSyncExecution
2326
from .bulk_sync_execution_envelope import BulkSyncExecutionEnvelope
2427
from .bulk_sync_execution_status import BulkSyncExecutionStatus
28+
from .bulk_sync_failed_event import BulkSyncFailedEvent
2529
from .bulk_sync_list_envelope import BulkSyncListEnvelope
2630
from .bulk_sync_response import BulkSyncResponse
2731
from .bulk_sync_response_envelope import BulkSyncResponseEnvelope
32+
from .bulk_sync_running_event import BulkSyncRunningEvent
2833
from .bulk_sync_schema_execution import BulkSyncSchemaExecution
2934
from .bulk_sync_schema_execution_status import BulkSyncSchemaExecutionStatus
3035
from .bulk_sync_source import BulkSyncSource
@@ -53,6 +58,7 @@
5358
from .create_model_request import CreateModelRequest
5459
from .enrichment import Enrichment
5560
from .event import Event
61+
from .event_body import EventBody
5662
from .event_types_envelope import EventTypesEnvelope
5763
from .events_envelope import EventsEnvelope
5864
from .execution_counts import ExecutionCounts
@@ -129,7 +135,12 @@
129135
from .start_model_sync_response_envelope import StartModelSyncResponseEnvelope
130136
from .start_model_sync_response_schema import StartModelSyncResponseSchema
131137
from .supported_mode import SupportedMode
138+
from .sync_canceled_event import SyncCanceledEvent
139+
from .sync_completed_event import SyncCompletedEvent
140+
from .sync_completed_with_errors_event import SyncCompletedWithErrorsEvent
132141
from .sync_destination_properties import SyncDestinationProperties
142+
from .sync_failed_event import SyncFailedEvent
143+
from .sync_running_event import SyncRunningEvent
133144
from .sync_status_envelope import SyncStatusEnvelope
134145
from .sync_status_response import SyncStatusResponse
135146
from .target import Target
@@ -169,14 +180,19 @@
169180
"BulkSchemaEnvelope",
170181
"BulkSchemaExecutionStatus",
171182
"BulkSelectiveMode",
183+
"BulkSyncCanceledEvent",
184+
"BulkSyncCompletedEvent",
185+
"BulkSyncCompletedWithErrorEvent",
172186
"BulkSyncDest",
173187
"BulkSyncDestEnvelope",
174188
"BulkSyncExecution",
175189
"BulkSyncExecutionEnvelope",
176190
"BulkSyncExecutionStatus",
191+
"BulkSyncFailedEvent",
177192
"BulkSyncListEnvelope",
178193
"BulkSyncResponse",
179194
"BulkSyncResponseEnvelope",
195+
"BulkSyncRunningEvent",
180196
"BulkSyncSchemaExecution",
181197
"BulkSyncSchemaExecutionStatus",
182198
"BulkSyncSource",
@@ -205,6 +221,7 @@
205221
"CreateModelRequest",
206222
"Enrichment",
207223
"Event",
224+
"EventBody",
208225
"EventTypesEnvelope",
209226
"EventsEnvelope",
210227
"ExecutionCounts",
@@ -281,7 +298,12 @@
281298
"StartModelSyncResponseEnvelope",
282299
"StartModelSyncResponseSchema",
283300
"SupportedMode",
301+
"SyncCanceledEvent",
302+
"SyncCompletedEvent",
303+
"SyncCompletedWithErrorsEvent",
284304
"SyncDestinationProperties",
305+
"SyncFailedEvent",
306+
"SyncRunningEvent",
285307
"SyncStatusEnvelope",
286308
"SyncStatusResponse",
287309
"Target",
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
# This file was auto-generated from our API Definition.
2+
3+
import datetime as dt
4+
import typing
5+
6+
from ..core.datetime_utils import serialize_datetime
7+
from ..core.pydantic_utilities import deep_union_pydantic_dicts, pydantic_v1
8+
9+
10+
class BulkSyncCanceledEvent(pydantic_v1.BaseModel):
11+
destination_connection_id: typing.Optional[str] = None
12+
execution_id: typing.Optional[str] = None
13+
name: typing.Optional[str] = None
14+
organization_id: typing.Optional[str] = None
15+
source_connection_id: typing.Optional[str] = None
16+
sync_id: typing.Optional[str] = None
17+
18+
def json(self, **kwargs: typing.Any) -> str:
19+
kwargs_with_defaults: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
20+
return super().json(**kwargs_with_defaults)
21+
22+
def dict(self, **kwargs: typing.Any) -> typing.Dict[str, typing.Any]:
23+
kwargs_with_defaults_exclude_unset: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
24+
kwargs_with_defaults_exclude_none: typing.Any = {"by_alias": True, "exclude_none": True, **kwargs}
25+
26+
return deep_union_pydantic_dicts(
27+
super().dict(**kwargs_with_defaults_exclude_unset), super().dict(**kwargs_with_defaults_exclude_none)
28+
)
29+
30+
class Config:
31+
frozen = True
32+
smart_union = True
33+
extra = pydantic_v1.Extra.allow
34+
json_encoders = {dt.datetime: serialize_datetime}
Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
# This file was auto-generated from our API Definition.
2+
3+
import datetime as dt
4+
import typing
5+
6+
from ..core.datetime_utils import serialize_datetime
7+
from ..core.pydantic_utilities import deep_union_pydantic_dicts, pydantic_v1
8+
9+
10+
class BulkSyncCompletedEvent(pydantic_v1.BaseModel):
11+
destination_connection_id: typing.Optional[str] = None
12+
execution_id: typing.Optional[str] = None
13+
name: typing.Optional[str] = None
14+
organization_id: typing.Optional[str] = None
15+
source_connection_id: typing.Optional[str] = None
16+
sync_id: typing.Optional[str] = None
17+
trigger_source: typing.Optional[str] = None
18+
19+
def json(self, **kwargs: typing.Any) -> str:
20+
kwargs_with_defaults: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
21+
return super().json(**kwargs_with_defaults)
22+
23+
def dict(self, **kwargs: typing.Any) -> typing.Dict[str, typing.Any]:
24+
kwargs_with_defaults_exclude_unset: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
25+
kwargs_with_defaults_exclude_none: typing.Any = {"by_alias": True, "exclude_none": True, **kwargs}
26+
27+
return deep_union_pydantic_dicts(
28+
super().dict(**kwargs_with_defaults_exclude_unset), super().dict(**kwargs_with_defaults_exclude_none)
29+
)
30+
31+
class Config:
32+
frozen = True
33+
smart_union = True
34+
extra = pydantic_v1.Extra.allow
35+
json_encoders = {dt.datetime: serialize_datetime}
Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
# This file was auto-generated from our API Definition.
2+
3+
import datetime as dt
4+
import typing
5+
6+
from ..core.datetime_utils import serialize_datetime
7+
from ..core.pydantic_utilities import deep_union_pydantic_dicts, pydantic_v1
8+
9+
10+
class BulkSyncCompletedWithErrorEvent(pydantic_v1.BaseModel):
11+
destination_connection_id: typing.Optional[str] = None
12+
execution_id: typing.Optional[str] = None
13+
name: typing.Optional[str] = None
14+
organization_id: typing.Optional[str] = None
15+
source_connection_id: typing.Optional[str] = None
16+
sync_id: typing.Optional[str] = None
17+
trigger_source: typing.Optional[str] = None
18+
19+
def json(self, **kwargs: typing.Any) -> str:
20+
kwargs_with_defaults: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
21+
return super().json(**kwargs_with_defaults)
22+
23+
def dict(self, **kwargs: typing.Any) -> typing.Dict[str, typing.Any]:
24+
kwargs_with_defaults_exclude_unset: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
25+
kwargs_with_defaults_exclude_none: typing.Any = {"by_alias": True, "exclude_none": True, **kwargs}
26+
27+
return deep_union_pydantic_dicts(
28+
super().dict(**kwargs_with_defaults_exclude_unset), super().dict(**kwargs_with_defaults_exclude_none)
29+
)
30+
31+
class Config:
32+
frozen = True
33+
smart_union = True
34+
extra = pydantic_v1.Extra.allow
35+
json_encoders = {dt.datetime: serialize_datetime}
Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
# This file was auto-generated from our API Definition.
2+
3+
import datetime as dt
4+
import typing
5+
6+
from ..core.datetime_utils import serialize_datetime
7+
from ..core.pydantic_utilities import deep_union_pydantic_dicts, pydantic_v1
8+
9+
10+
class BulkSyncFailedEvent(pydantic_v1.BaseModel):
11+
destination_connection_id: typing.Optional[str] = None
12+
error: typing.Optional[str] = None
13+
execution_id: typing.Optional[str] = None
14+
name: typing.Optional[str] = None
15+
organization_id: typing.Optional[str] = None
16+
source_connection_id: typing.Optional[str] = None
17+
sync_id: typing.Optional[str] = None
18+
19+
def json(self, **kwargs: typing.Any) -> str:
20+
kwargs_with_defaults: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
21+
return super().json(**kwargs_with_defaults)
22+
23+
def dict(self, **kwargs: typing.Any) -> typing.Dict[str, typing.Any]:
24+
kwargs_with_defaults_exclude_unset: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
25+
kwargs_with_defaults_exclude_none: typing.Any = {"by_alias": True, "exclude_none": True, **kwargs}
26+
27+
return deep_union_pydantic_dicts(
28+
super().dict(**kwargs_with_defaults_exclude_unset), super().dict(**kwargs_with_defaults_exclude_none)
29+
)
30+
31+
class Config:
32+
frozen = True
33+
smart_union = True
34+
extra = pydantic_v1.Extra.allow
35+
json_encoders = {dt.datetime: serialize_datetime}
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
# This file was auto-generated from our API Definition.
2+
3+
import datetime as dt
4+
import typing
5+
6+
from ..core.datetime_utils import serialize_datetime
7+
from ..core.pydantic_utilities import deep_union_pydantic_dicts, pydantic_v1
8+
9+
10+
class BulkSyncRunningEvent(pydantic_v1.BaseModel):
11+
destination_connection_id: typing.Optional[str] = None
12+
execution_id: typing.Optional[str] = None
13+
name: typing.Optional[str] = None
14+
organization_id: typing.Optional[str] = None
15+
source_connection_id: typing.Optional[str] = None
16+
sync_id: typing.Optional[str] = None
17+
18+
def json(self, **kwargs: typing.Any) -> str:
19+
kwargs_with_defaults: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
20+
return super().json(**kwargs_with_defaults)
21+
22+
def dict(self, **kwargs: typing.Any) -> typing.Dict[str, typing.Any]:
23+
kwargs_with_defaults_exclude_unset: typing.Any = {"by_alias": True, "exclude_unset": True, **kwargs}
24+
kwargs_with_defaults_exclude_none: typing.Any = {"by_alias": True, "exclude_none": True, **kwargs}
25+
26+
return deep_union_pydantic_dicts(
27+
super().dict(**kwargs_with_defaults_exclude_unset), super().dict(**kwargs_with_defaults_exclude_none)
28+
)
29+
30+
class Config:
31+
frozen = True
32+
smart_union = True
33+
extra = pydantic_v1.Extra.allow
34+
json_encoders = {dt.datetime: serialize_datetime}

0 commit comments

Comments
 (0)