fix string limit pagination

Author: aIbrahiim

sdks/python/apache_beam/io/gcp/healthcare/dicomclient.py

@@ -65,7 +65,7 @@ def qido_search(
     page_size = 500
 
     if params and 'limit' in params:
-      page_size = params['limit']
+      page_size = int(params['limit'])
     elif params:
       params['limit'] = page_size
     else:

sdks/python/apache_beam/yaml/extended_tests/databases/dicom.yaml

@@ -42,29 +42,3 @@ pipelines:
               - {status: "200"}
     options:
       project: "apache-beam-testing"
-
-  - pipeline:
-      type: chain
-      transforms:
-        - type: Create
-          config:
-            elements:
-              - project_id: "apache-beam-testing"
-                region: "us-central1"
-                dataset_id: "apache-beam-integration-testing"
-                dicom_store_id: "dicom_it_persistent_store"
-                search_type: "instances"
-                params:
-                  StudyInstanceUID: "study_000000001"
-        - type: DicomSearch
-        - type: MapToFields
-          config:
-            language: python
-            fields:
-              status: status
-        - type: AssertEqual
-          config:
-            elements:
-              - {status: "200"}
-    options:
-      project: "apache-beam-testing"

sdks/python/apache_beam/yaml/yaml_io.py

@@ -1003,16 +1003,16 @@ def row_to_dict(value):
       return value
 
   def normalize_request(value):
-    # YAML Create often types params as map[str, str]; qido_search needs
-    # int limit/offset for pagination comparisons.
+    # YAML Create types params as map[str, str]; qido_search needs int
+    # limit/offset for pagination comparisons.
     request = row_to_dict(value)
     params = request.get('params')
-    if isinstance(params, Mapping):
-      params = dict(params)
-      for key in ('limit', 'offset'):
-        if key in params and params[key] is not None:
-          params[key] = int(params[key])
-      request['params'] = params
+    params = dict(params) if isinstance(params, Mapping) else {}
+    limit = params.get('limit', 500)
+    offset = params.get('offset', 0)
+    params['limit'] = int(limit)
+    params['offset'] = int(offset)
+    request['params'] = params
     return request
 
   if error_handling: