Skip to content

Commit 6a64a33

Browse files
committed
Better version
1 parent 0a354b2 commit 6a64a33

6 files changed

Lines changed: 1386 additions & 106 deletions

File tree

python/pyspark/sql/connect/proto/base_pb2.py

Lines changed: 9 additions & 9 deletions
Large diffs are not rendered by default.

python/pyspark/sql/connect/proto/base_pb2.pyi

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4759,6 +4759,9 @@ class ListSqlExecutionsResponse(google.protobuf.message.Message):
47594759
COMPLETION_TIME_MS_FIELD_NUMBER: builtins.int
47604760
ERROR_MESSAGE_FIELD_NUMBER: builtins.int
47614761
JOB_IDS_FIELD_NUMBER: builtins.int
4762+
QUERY_ID_FIELD_NUMBER: builtins.int
4763+
DETAILS_FIELD_NUMBER: builtins.int
4764+
STAGE_COUNT_FIELD_NUMBER: builtins.int
47624765
execution_id: builtins.int
47634766
root_execution_id: builtins.int
47644767
description: builtins.str
@@ -4774,6 +4777,14 @@ class ListSqlExecutionsResponse(google.protobuf.message.Message):
47744777
"""Job IDs associated with this execution. Job statuses are not included; clients can look
47754778
them up via the existing /api/v1/applications/{appId}/jobs REST endpoint if needed.
47764779
"""
4780+
query_id: builtins.str
4781+
"""UUID assigned by SQLExecution; null for executions recovered from old event logs."""
4782+
details: builtins.str
4783+
"""Long form of the call site for the executing SQL/DataFrame operation. For Connect
4784+
executions this is set to a redacted, abbreviated rendering of the ExecutePlanRequest.
4785+
"""
4786+
stage_count: builtins.int
4787+
"""Number of Spark stages associated with this execution."""
47774788
def __init__(
47784789
self,
47794790
*,
@@ -4785,39 +4796,60 @@ class ListSqlExecutionsResponse(google.protobuf.message.Message):
47854796
completion_time_ms: builtins.int | None = ...,
47864797
error_message: builtins.str | None = ...,
47874798
job_ids: collections.abc.Iterable[builtins.int] | None = ...,
4799+
query_id: builtins.str | None = ...,
4800+
details: builtins.str | None = ...,
4801+
stage_count: builtins.int = ...,
47884802
) -> None: ...
47894803
def HasField(
47904804
self,
47914805
field_name: typing_extensions.Literal[
47924806
"_completion_time_ms",
47934807
b"_completion_time_ms",
4808+
"_details",
4809+
b"_details",
47944810
"_error_message",
47954811
b"_error_message",
4812+
"_query_id",
4813+
b"_query_id",
47964814
"completion_time_ms",
47974815
b"completion_time_ms",
4816+
"details",
4817+
b"details",
47984818
"error_message",
47994819
b"error_message",
4820+
"query_id",
4821+
b"query_id",
48004822
],
48014823
) -> builtins.bool: ...
48024824
def ClearField(
48034825
self,
48044826
field_name: typing_extensions.Literal[
48054827
"_completion_time_ms",
48064828
b"_completion_time_ms",
4829+
"_details",
4830+
b"_details",
48074831
"_error_message",
48084832
b"_error_message",
4833+
"_query_id",
4834+
b"_query_id",
48094835
"completion_time_ms",
48104836
b"completion_time_ms",
48114837
"description",
48124838
b"description",
4839+
"details",
4840+
b"details",
48134841
"error_message",
48144842
b"error_message",
48154843
"execution_id",
48164844
b"execution_id",
48174845
"job_ids",
48184846
b"job_ids",
4847+
"query_id",
4848+
b"query_id",
48194849
"root_execution_id",
48204850
b"root_execution_id",
4851+
"stage_count",
4852+
b"stage_count",
48214853
"status",
48224854
b"status",
48234855
"submission_time_ms",
@@ -4830,9 +4862,17 @@ class ListSqlExecutionsResponse(google.protobuf.message.Message):
48304862
oneof_group: typing_extensions.Literal["_completion_time_ms", b"_completion_time_ms"],
48314863
) -> typing_extensions.Literal["completion_time_ms"] | None: ...
48324864
@typing.overload
4865+
def WhichOneof(
4866+
self, oneof_group: typing_extensions.Literal["_details", b"_details"]
4867+
) -> typing_extensions.Literal["details"] | None: ...
4868+
@typing.overload
48334869
def WhichOneof(
48344870
self, oneof_group: typing_extensions.Literal["_error_message", b"_error_message"]
48354871
) -> typing_extensions.Literal["error_message"] | None: ...
4872+
@typing.overload
4873+
def WhichOneof(
4874+
self, oneof_group: typing_extensions.Literal["_query_id", b"_query_id"]
4875+
) -> typing_extensions.Literal["query_id"] | None: ...
48364876

48374877
SESSION_ID_FIELD_NUMBER: builtins.int
48384878
SERVER_SIDE_SESSION_ID_FIELD_NUMBER: builtins.int

0 commit comments

Comments
 (0)