Merge pull request #372 from ydb-platform/arc-sync

* Added YDB convert support EmptyDict, EmptyList types
* Added EXTERNAL_ERROR status code and issue ExternalError

Author: rekby

CHANGELOG.md

@@ -1,3 +1,6 @@
+* Added YDB convert support EmptyDict, EmptyList types
+* Added EXTERNAL_ERROR status code and issue ExternalError
+
 ## 2.13.4 ##
 * Fixed set keep_in_cache algorithm
 

ydb/_tx_ctx_impl.py

@@ -152,6 +152,7 @@ def execute_request_factory(
 
     if keep_in_cache:
         request.query_cache_policy.keep_in_cache = True
+
     request.query.MergeFrom(query_pb)
     tx_control = _apis.ydb_table.TransactionControl()
     tx_control.commit_tx = commit_tx

ydb/convert.py

@@ -125,6 +125,8 @@ def _pb_to_void(type_pb, value_pb, table_client_settings):
     "dict_type": _pb_to_dict,
     "struct_type": _pb_to_struct,
     "void_type": _pb_to_void,
+    "empty_list_type": _pb_to_list,
+    "empty_dict_type": _pb_to_dict,
 }
 
 

ydb/issues.py

@@ -32,6 +32,7 @@ class StatusCode(enum.IntEnum):
     UNDETERMINED = _apis.StatusIds.UNDETERMINED
     UNSUPPORTED = _apis.StatusIds.UNSUPPORTED
     SESSION_BUSY = _apis.StatusIds.SESSION_BUSY
+    EXTERNAL_ERROR = _apis.StatusIds.EXTERNAL_ERROR
 
     CONNECTION_LOST = _TRANSPORT_STATUSES_FIRST + 10
     CONNECTION_FAILURE = _TRANSPORT_STATUSES_FIRST + 20
@@ -152,6 +153,10 @@ class SessionBusy(Error):
     status = StatusCode.SESSION_BUSY
 
 
+class ExternalError(Error):
+    status = StatusCode.EXTERNAL_ERROR
+
+
 class SessionPoolEmpty(Error, queue.Empty):
     status = StatusCode.SESSION_POOL_EMPTY
 
@@ -191,6 +196,7 @@ def _format_response(response):
     StatusCode.UNDETERMINED: Undetermined,
     StatusCode.UNSUPPORTED: Unsupported,
     StatusCode.SESSION_BUSY: SessionBusy,
+    StatusCode.EXTERNAL_ERROR: ExternalError,
 }