Added search_pipeline (#227)

* Added search_pipeline Signed-off-by: Theo Truong <[email protected]> * # Signed-off-by: Theo Truong <[email protected]> --------- Signed-off-by: Theo Truong <[email protected]>
opensearch-project · Jan 31, 2024 · 221eb68 · 221eb68
1 parent 97fac2a
commit 221eb68
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -4,10 +4,12 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
 ## [Unreleased]
 ### Added
 - Added support for Ruby 3.3 ([#220](https://github.com/opensearch-project/opensearch-ruby/pull/220))
+- Added `search_pipeline` parameter to `search` API ([#227](https://github.com/opensearch-project/opensearch-ruby/pull/227))
 ### Changed
 ### Deprecated
 ### Removed
 - Removed dependency on the base64 gem ([#221](https://github.com/opensearch-project/opensearch-ruby/pull/221))
+- Removed logging of hosts in `transport` base ([#227](https://github.com/opensearch-project/opensearch-ruby/pull/227))
 ### Fixed
 - Switch back to the latest OpenSearch version when testing in CI ([#219](https://github.com/opensearch-project/opensearch-ruby/pull/219))
 ### Security

diff --git a/lib/opensearch/api/actions/search.rb b/lib/opensearch/api/actions/search.rb
@@ -48,6 +48,7 @@ module Actions
       # @option arguments [String] :q Query in the Lucene query string syntax
       # @option arguments [List] :routing A comma-separated list of specific routing values
       # @option arguments [Time] :scroll Specify how long a consistent view of the index should be maintained for scrolled search
+      # @option arguments [String] :search_pipeline Customizable sequence of processing stages applied to search queries.
       # @option arguments [String] :search_type Search operation type (options: query_then_fetch, dfs_query_then_fetch)
       # @option arguments [Number] :size Number of hits to return (default: 10)
       # @option arguments [List] :sort A comma-separated list of <field>:<direction> pairs
@@ -128,6 +129,7 @@ def search(arguments = {})
         q
         routing
         scroll
+        search_pipeline
         search_type
         size
         sort

diff --git a/lib/opensearch/transport/transport/base.rb b/lib/opensearch/transport/transport/base.rb
@@ -104,9 +104,7 @@ def get_connection(options = {})
         # @see Sniffer#hosts
         #
         def reload_connections!
-          puts hosts
           hosts = sniffer.hosts
-          puts hosts
           __rebuild_connections hosts: hosts, options: options
           self
         rescue SnifferTimeoutError