Skip to content

Commit d38b7f7

Browse files
committed
Minor fixes
1 parent b1b5568 commit d38b7f7

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

singlestoredb/fusion/handlers/export.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -162,7 +162,7 @@ def _start_export(params: Dict[str, Any]) -> Optional[FusionSQLResult]:
162162
refresh_interval = params.get('refresh_interval', None)
163163
if refresh_interval is not None:
164164
value = int(refresh_interval['refresh_interval_value'])
165-
time_unit = refresh_interval['refresh_interval_time_unit']
165+
time_unit = refresh_interval['refresh_interval_time_unit'].upper()
166166
if value < 0:
167167
raise ValueError('refresh interval must be greater than 0')
168168
if time_unit == 'SECONDS':

singlestoredb/management/export.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ def start(self, tags: Optional[List[str]] = None) -> 'ExportStatus':
155155
partitionSpec=partition_spec,
156156
sortOrderSpec=sort_order_spec,
157157
properties=self.properties,
158-
incremental=self.incremental,
158+
incremental=self.incremental or None,
159159
refreshInterval=self.refresh_interval.total_seconds()
160160
if self.refresh_interval is not None else None,
161161
).items() if v is not None

0 commit comments

Comments
 (0)