Skip to content

Commit 9c10946

Browse files
committed
Revert "Managed Streaming Should Handle Throttling Events Correctly"
This reverts commit eaf9b70.
1 parent eaf9b70 commit 9c10946

File tree

2 files changed

+3
-8
lines changed

2 files changed

+3
-8
lines changed

CHANGELOG.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
88
## [Unreleased]
99

1010
### Fixed
11-
- Managed Streaming Should Handle Throttling Events Correctly
1211
- Changed extra's name back to `aio`
1312
- Fixed encoding error in `ingest_from_dataframe` when using csv data format.
1413

azure-kusto-ingest/azure/kusto/ingest/managed_streaming_ingest_client.py

Lines changed: 3 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
from azure.core.tracing import SpanKind
1010

1111
from azure.kusto.data import KustoConnectionStringBuilder
12-
from azure.kusto.data.exceptions import KustoApiError, KustoClosedError, KustoThrottlingError
12+
from azure.kusto.data.exceptions import KustoApiError, KustoClosedError
1313
from azure.kusto.data._telemetry import MonitoredActivity
1414

1515
from . import BlobDescriptor, FileDescriptor, IngestionProperties, StreamDescriptor
@@ -99,9 +99,7 @@ def ingest_from_stream(self, stream_descriptor: Union[StreamDescriptor, IO[AnySt
9999
if error.permanent:
100100
raise
101101
buffered_stream.seek(0, SEEK_SET)
102-
except KustoThrottlingError:
103-
_ = buffered_stream.seek(0, SEEK_SET)
104-
102+
105103
return self.queued_client.ingest_from_stream(stream_descriptor, ingestion_properties)
106104

107105
@distributed_trace(kind=SpanKind.CLIENT)
@@ -129,9 +127,7 @@ def ingest_from_blob(self, blob_descriptor: BlobDescriptor, ingestion_properties
129127
error = ex.get_api_error()
130128
if error.permanent:
131129
raise
132-
except KustoThrottlingError:
133-
pass
134-
130+
135131
return self.queued_client.ingest_from_blob(blob_descriptor, ingestion_properties)
136132

137133
def _stream_with_retries(

0 commit comments

Comments
 (0)