make base private

sdk/cosmos/azure-cosmos/azure/cosmos/_cosmos_client_connection.py

@@ -25,7 +25,7 @@
 
 import six
 from typing import cast
-from . import base
+from . import _base as base
 from . import documents
 from . import _constants as constants
 from . import http_constants

sdk/cosmos/azure-cosmos/azure/cosmos/_execution_context/base_execution_context.py

@@ -25,7 +25,7 @@
 from collections import deque
 from .. import _retry_utility
 from .. import http_constants
-from .. import base
+from .. import _base
 
 class _QueryExecutionContextBase(object):
     """
@@ -208,8 +208,8 @@ def __init__(self, client, options, database_link, query, partition_key):
             raise ValueError("_collection_links_length is not greater than 0.")
 
         # Creating the QueryFeed for the first collection
-        path = base.GetPathFromLink(self._collection_links[self._current_collection_index], 'docs')
-        collection_id = base.GetResourceIdOrFullNameFromLink(self._collection_links[self._current_collection_index])
+        path = _base.GetPathFromLink(self._collection_links[self._current_collection_index], 'docs')
+        collection_id = _base.GetResourceIdOrFullNameFromLink(self._collection_links[self._current_collection_index])
 
         self._current_collection_index += 1
 
@@ -241,8 +241,8 @@ def _fetch_next_block(self):
         # creating separate feed queries for each collection and fetching the items
         while not fetched_items:
             if self._collection_links and self._current_collection_index < self._collection_links_length:
-                path = base.GetPathFromLink(self._collection_links[self._current_collection_index], 'docs')
-                collection_id = base.GetResourceIdOrFullNameFromLink(self._collection_links[self._current_collection_index])
+                path = _base.GetPathFromLink(self._collection_links[self._current_collection_index], 'docs')
+                collection_id = _base.GetResourceIdOrFullNameFromLink(self._collection_links[self._current_collection_index])
 
                 self._continuation = None
                 self._has_started = False

sdk/cosmos/azure-cosmos/azure/cosmos/_execution_context/document_producer.py

@@ -25,7 +25,7 @@
 import six
 import numbers
 from collections import deque
-from azure.cosmos import base
+from azure.cosmos import _base
 from azure.cosmos._execution_context.base_execution_context import _DefaultQueryExecutionContext
 from six.moves import xrange
 
@@ -51,8 +51,8 @@ def __init__(self, partition_key_target_range, client, collection_link, query, d
         self._cur_item = None
         # initiate execution context
 
-        path = base.GetPathFromLink(collection_link, 'docs')
-        collection_id = base.GetResourceIdOrFullNameFromLink(collection_link)
+        path = _base.GetPathFromLink(collection_link, 'docs')
+        collection_id = _base.GetResourceIdOrFullNameFromLink(collection_link)
         def fetch_fn(options):
                 return self._client.QueryFeed(path,
                                         collection_id,

sdk/cosmos/azure-cosmos/azure/cosmos/_location_cache.py

@@ -25,7 +25,6 @@
 import collections
 import time
 
-from . import base
 from . import documents
 from . import http_constants
 

sdk/cosmos/azure-cosmos/azure/cosmos/_routing/routing_map_provider.py

@@ -22,7 +22,7 @@
 """Internal class for partition key range cache implementation in the Azure Cosmos database service.
 """
 
-from .. import base
+from .. import _base
 from .collection_routing_map import CollectionRoutingMap
 from . import routing_range
 from .routing_range import PartitionKeyRange
@@ -59,7 +59,7 @@ def get_overlapping_ranges(self, collection_link, partition_key_ranges):
         '''
         cl = self._documentClient
 
-        collection_id = base.GetResourceIdOrFullNameFromLink(collection_link)
+        collection_id = _base.GetResourceIdOrFullNameFromLink(collection_link)
 
         collection_routing_map = self._collection_routing_map_by_item.get(collection_id)
         if collection_routing_map is None:

sdk/cosmos/azure-cosmos/azure/cosmos/_session.py

@@ -25,7 +25,7 @@
 import sys, traceback
 import threading
 
-from . import base
+from . import _base
 from . import http_constants
 from ._vector_session_token import VectorSessionToken
 from .errors import HTTPFailure
@@ -51,17 +51,17 @@ def get_session_token(self, resource_path):
         """
 
         with self.session_lock:
-            is_name_based = base.IsNameBased(resource_path)
+            is_name_based = _base.IsNameBased(resource_path)
             collection_rid = ''
             session_token = ''
 
             try:
                 if is_name_based:
                     # get the collection name
-                    collection_name = base.GetItemContainerLink(resource_path)
+                    collection_name = _base.GetItemContainerLink(resource_path)
                     collection_rid = self.collection_name_to_rid[collection_name]
                 else:
-                    collection_rid = base.GetItemContainerLink(resource_path)
+                    collection_rid = _base.GetItemContainerLink(resource_path)
 
                 if collection_rid in self.rid_to_session_token:
                     token_dict = self.rid_to_session_token[collection_rid]
@@ -112,7 +112,7 @@ def set_session_token(self, response_result, response_headers):
                     response_result_id = response_result[response_result_id_key]
                 else:
                     return
-                collection_rid, collection_name = base.GetItemContainerInfo(self_link, alt_content_path, response_result_id)
+                collection_rid, collection_name = _base.GetItemContainerInfo(self_link, alt_content_path, response_result_id)
 
             except ValueError:
                 return

sdk/cosmos/azure-cosmos/azure/cosmos/_vector_session_token.py

@@ -23,7 +23,6 @@
 """
 
 from . import errors
-from . import base
 from .http_constants import StatusCodes
 
 class VectorSessionToken(object):

sdk/cosmos/azure-cosmos/samples/MultiMasterOperations/ConflictWorker.py

@@ -4,7 +4,6 @@
 import json
 import azure.cosmos.errors as errors
 from azure.cosmos.http_constants import StatusCodes
-import azure.cosmos.base as base
 
 class ConflictWorker(object):
     def __init__(self, database_name, basic_collection_name, manual_collection_name, lww_collection_name, udp_collection_name):

sdk/cosmos/azure-cosmos/test/base_unit_tests.py

@@ -1,6 +1,6 @@
 import unittest
 import pytest
-import azure.cosmos.base as base
+import azure.cosmos._base as base
 
 pytestmark = pytest.mark.cosmosEmulator
 

sdk/cosmos/azure-cosmos/test/crud_tests.py

@@ -47,7 +47,7 @@
 from azure.cosmos.http_constants import HttpHeaders, StatusCodes, SubStatusCodes
 import azure.cosmos._murmur_hash as _murmur_hash
 import test_config
-import azure.cosmos.base as base
+import azure.cosmos._base as base
 import azure.cosmos.cosmos_client as cosmos_client
 from azure.cosmos.diagnostics import RecordDiagnostics
 from azure.cosmos.partition_key import PartitionKey

sdk/cosmos/azure-cosmos/test/orderby_tests.py

@@ -26,7 +26,7 @@
 from azure.cosmos.partition_key import PartitionKey
 import azure.cosmos.cosmos_client as cosmos_client
 from azure.cosmos import _query_iterable as query_iterable
-import azure.cosmos.base as base
+import azure.cosmos._base as base
 from six.moves import xrange
 import test_config
 

sdk/cosmos/azure-cosmos/test/query_execution_context_tests.py

@@ -25,7 +25,7 @@
 from six.moves import xrange
 import azure.cosmos.cosmos_client as cosmos_client
 from azure.cosmos._execution_context import base_execution_context as base_execution_context
-import azure.cosmos.base as base
+import azure.cosmos._base as base
 import test_config
 from azure.cosmos.partition_key import PartitionKey