You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by vt...@apache.org on 2026/05/04 12:45:44 UTC

(beam) 01/01: Revert changes from fhirio/common.go

This is an automated email from the ASF dual-hosted git repository.

Amar3tto pushed a commit to branch fix-postcommit-go
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 95e8c588d6cd64e85126bf0553b8aeba05df32f3
Author: Vitaly Terentyev <vi...@akvelon.com>
AuthorDate: Mon May 4 16:45:28 2026 +0400

    Revert changes from fhirio/common.go
---
 sdks/go/pkg/beam/io/fhirio/common.go | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/sdks/go/pkg/beam/io/fhirio/common.go b/sdks/go/pkg/beam/io/fhirio/common.go
index 504e65270d5..75781f7ba0c 100644
--- a/sdks/go/pkg/beam/io/fhirio/common.go
+++ b/sdks/go/pkg/beam/io/fhirio/common.go
@@ -127,12 +127,11 @@ func (c *fhirStoreClientImpl) search(storePath, resourceType string, queries map
 		queryParams = append(queryParams, googleapi.QueryParameter(pageTokenParameterKey, pageToken))
 	}
 
-	// Pass nil as the body because search parameters are passed via queryParams,
-	// and the new API expects an io.Reader instead of a specific struct.
+	searchRequest := &healthcare.SearchResourcesRequest{}
 	if resourceType == "" {
-		return c.fhirService().Search(storePath, nil).Do(queryParams...)
+		return c.fhirService().Search(storePath, searchRequest).Do(queryParams...)
 	}
-	return c.fhirService().SearchType(storePath, resourceType, nil).Do(queryParams...)
+	return c.fhirService().SearchType(storePath, resourceType, searchRequest).Do(queryParams...)
 }
 
 func (c *fhirStoreClientImpl) deidentify(srcStorePath, dstStorePath string, deidConfig *healthcare.DeidentifyConfig) (operationResults, error) {