| 15 | |
| 16 | @dataclass(frozen=True) |
| 17 | class DataSourceOptions: |
| 18 | commit_duration_ms: int | None = None |
| 19 | unsafe_trusted_ids: bool | None = False |
| 20 | unique_name: str | None = None |
| 21 | synchronization_group: api.ConnectorGroupDescriptor | None = None |
| 22 | max_backlog_size: int | None = None |
| 23 | |
| 24 | def set_synchronization_group(self, group: api.ConnectorGroupDescriptor | None): |
| 25 | if self.synchronization_group is None: |
| 26 | object.__setattr__(self, "synchronization_group", group) |
| 27 | else: |
| 28 | raise ValueError("synchronization_group can only be set once") |
| 29 | |
| 30 | |
| 31 | @dataclass(frozen=True, kw_only=True) |
no outgoing calls
no test coverage detected