[source-opsgenie] Add Alert Notes

[anamargaridarl]

I would like to add the stream Alert Notes to the Opsgenie connector. Link

However, I’m trying to run cursor pagination without success. The stop condition occurs when the response data does not have a “paging” key. However, the connector is getting stuck in a loop without providing any logs on what is happening. Does anyone know what might be the cause?
For reference, this is the Opsgenie Alert API, and here is the yaml file for the stream:

AlertNotes:
      type: DeclarativeStream
      name: AlertNotes
      primary_key:
        - offset
        - alert_id
      retriever:
        type: SimpleRetriever
        requester:
          $ref: "#/definitions/base_requester"
          path: v2/alerts/{{ stream_partition['id'] }}/notes
          http_method: GET
          request_parameters:
            limit: "100"
            order: desc
            identifierType: id
          error_handler:
            type: CompositeErrorHandler
            error_handlers:
              - type: DefaultErrorHandler
                max_retries: 10
                backoff_strategies:
                  - type: WaitUntilTimeFromHeader
                    header: X-RateLimit-Period-In-Sec
              - type: DefaultErrorHandler
        record_selector:
          type: RecordSelector
          extractor:
            type: DpathExtractor
            field_path:
              - data
        paginator:
          type: DefaultPaginator
          page_token_option:
            type: RequestPath
          pagination_strategy:
            type: CursorPagination
            cursor_value: "{{ response.get(\"paging\", {}).get(\"next\", {}) }}"
            stop_condition: "{{ not response.get(\"paging\", {}).get(\"next\", {}) }}"
        partition_router:
          type: SubstreamPartitionRouter
          parent_stream_configs:
            - type: ParentStreamConfig
              parent_key: id
              partition_field: id
              stream:
                $ref: "#/definitions/streams/Alerts"
      transformations:
        - type: AddFields
          fields:
            - path:
                - alert_id
              value: "{{ stream_partition['id'] }}"
      schema_loader:
        type: InlineSchemaLoader
        schema:
          $ref: "#/schemas/AlertNotes"