Skip to content

Commit 734321a

Browse files
Merge branch 'sea-migration' into fetch-json-inline
2 parents 21c389d + 677a7b0 commit 734321a

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

src/databricks/sql/backend/sea/backend.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -354,7 +354,7 @@ def _results_message_to_execute_response(
354354
description=description,
355355
has_been_closed_server_side=False,
356356
lz4_compressed=lz4_compressed,
357-
is_staging_operation=False,
357+
is_staging_operation=response.manifest.is_volume_operation,
358358
arrow_schema_bytes=None,
359359
result_format=response.manifest.format,
360360
)

src/databricks/sql/backend/sea/models/base.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,4 +92,4 @@ class ResultManifest:
9292
truncated: bool = False
9393
chunks: Optional[List[ChunkInfo]] = None
9494
result_compression: Optional[str] = None
95-
is_volume_operation: Optional[bool] = None
95+
is_volume_operation: bool = False

src/databricks/sql/backend/sea/models/responses.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ def _parse_manifest(data: Dict[str, Any]) -> ResultManifest:
6565
truncated=manifest_data.get("truncated", False),
6666
chunks=chunks,
6767
result_compression=manifest_data.get("result_compression"),
68-
is_volume_operation=manifest_data.get("is_volume_operation"),
68+
is_volume_operation=manifest_data.get("is_volume_operation", False),
6969
)
7070

7171

0 commit comments

Comments
 (0)