Skip to content

Commit

Permalink
Added async support for helpers that are merged from opensearch-dsl-py
Browse files Browse the repository at this point in the history
Signed-off-by: saimedhi <saimedhi@amazon.com>
  • Loading branch information
saimedhi committed Mar 16, 2023
1 parent 409c883 commit a867bda
Show file tree
Hide file tree
Showing 40 changed files with 7,226 additions and 63 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)

## [Unreleased]
### Added
- Added async support for helpers that are merged from opensearch-dsl-py ([#329](https://github.com/opensearch-project/opensearch-py/pull/329))
### Changed
### Deprecated
### Removed
Expand Down
8 changes: 8 additions & 0 deletions opensearchpy/_async/helpers/__init__.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,8 @@
# SPDX-License-Identifier: Apache-2.0
#
# The OpenSearch Contributors require contributions made to
# this file be licensed under the Apache-2.0 license or a
# compatible open source license.
#
# Modifications Copyright OpenSearch Contributors. See
# GitHub history for details.
Original file line number Diff line number Diff line change
Expand Up @@ -32,15 +32,15 @@
import asyncio
import logging

from ..compat import map
from ..exceptions import TransportError
from ..helpers.actions import (
from ...compat import map
from ...exceptions import TransportError
from ...helpers.actions import (
_ActionChunker,
_process_bulk_chunk_error,
_process_bulk_chunk_success,
expand_action,
)
from ..helpers.errors import ScanError
from ...helpers.errors import ScanError

logger = logging.getLogger("opensearchpy.helpers")

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,8 +41,8 @@ from typing import (
Union,
)

from ..serializer import Serializer
from .client import AsyncOpenSearch
from ...serializer import Serializer
from ..client import AsyncOpenSearch

logger: logging.Logger

Expand Down
Loading

0 comments on commit a867bda

Please sign in to comment.