Removed 'out/opensearchpy' folder which was produced while generating pyi files for plugins

CHANGELOG.md

@@ -41,6 +41,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 
 ### Removed
 - Removed patch versions in integration tests for OpenSearch 1.0.0 - 2.3.0 to reduce Github Action jobs ([#262](https://github.com/opensearch-project/opensearch-py/pull/262))
+- Removed 'out/opensearchpy' folder which was produced while generating pyi files for plugins ([#288](https://github.com/opensearch-project/opensearch-py/pull/288))
 ### Fixed
 - Fixed DeprecationWarning emitted from urllib3 1.26.13+ ([#246](https://github.com/opensearch-project/opensearch-py/pull/246))
 ### Security

opensearchpy/_async/helpers.py

@@ -143,7 +143,6 @@ async def async_streaming_bulk(
     *args,
     **kwargs
 ):
-
     """
     Streaming bulk consumes actions from the iterable passed in and yields
     results per action. For non-streaming usecases use
@@ -185,7 +184,6 @@ async def map_actions():
     async for bulk_data, bulk_actions in _chunk_actions(
         map_actions(), chunk_size, max_chunk_bytes, client.transport.serializer
     ):
-
         for attempt in range(max_retries + 1):
             to_retry, to_retry_data = [], []
             if attempt:
@@ -207,7 +205,6 @@ async def map_actions():
                         **kwargs,
                     ),
                 ):
-
                     if not ok:
                         action, info = info.popitem()
                         # retry if retries enabled, we get 429, and we are not
@@ -422,7 +419,6 @@ async def async_reindex(
     scan_kwargs={},
     bulk_kwargs={},
 ):
-
     """
     Reindex all documents from one index that satisfy a given query
     to another, potentially (if `target_client` is specified) on a different cluster.

opensearchpy/_async/transport.py

@@ -160,7 +160,6 @@ async def _async_init(self):
 
         # ... and we can start sniffing in the background.
         if self.sniffing_task is None and self.sniff_on_start:
-
             # Create an asyncio.Event for future calls to block on
             # until the initial sniffing task completes.
             self._sniff_on_start_event = asyncio.Event()

opensearchpy/connection/http_async.py

@@ -196,7 +196,6 @@ async def perform_request(
 
         start = self.loop.time()
         try:
-
             async with self.session.request(
                 method,
                 url,

opensearchpy/helpers/actions.py

@@ -280,7 +280,6 @@ def streaming_bulk(
     *args,
     **kwargs
 ):
-
     """
     Streaming bulk consumes actions from the iterable passed in and yields
     results per action. For non-streaming usecases use
@@ -319,7 +318,6 @@ def streaming_bulk(
     for bulk_data, bulk_actions in _chunk_actions(
         actions, chunk_size, max_chunk_bytes, client.transport.serializer
     ):
-
         for attempt in range(max_retries + 1):
             to_retry, to_retry_data = [], []
             if attempt:
@@ -339,7 +337,6 @@ def streaming_bulk(
                         **kwargs
                     ),
                 ):
-
                     if not ok:
                         action, info = info.popitem()
                         # retry if retries enabled, we get 429, and we are not
@@ -621,7 +618,6 @@ def reindex(
     scan_kwargs={},
     bulk_kwargs={},
 ):
-
     """
     Reindex all documents from one index that satisfy a given query
     to another, potentially (if `target_client` is specified) on a different cluster.

opensearchpy/transport.py

@@ -197,13 +197,14 @@ def set_connections(self, hosts):
 
         :arg hosts: same as `__init__`
         """
+
         # construct the connections
         def _create_connection(host):
             # if this is not the initial setup look at the existing connection
             # options and identify connections that haven't changed and can be
             # kept around.
             if hasattr(self, "connection_pool"):
-                for (connection, old_host) in self.connection_pool.connection_opts:
+                for connection, old_host in self.connection_pool.connection_opts:
                     if old_host == host:
                         return connection
 

test_opensearchpy/test_async/test_server/test_helpers.py

@@ -530,7 +530,6 @@ async def test_initial_search_error(self, async_client, scan_teardown):
                 ),
             ):
                 with patch.object(async_client, "scroll", MockScroll()):
-
                     data = [
                         x
                         async for x in helpers.async_scan(
@@ -554,7 +553,6 @@ async def test_initial_search_error(self, async_client, scan_teardown):
                 ),
             ):
                 with patch.object(async_client, "scroll", MockScroll()) as mock_scroll:
-
                     with pytest.raises(ScanError):
                         data = [
                             x