Ansible: How to wait_for service on one of many hosts?

I'm using Ansible to spin up a service on my hosts to conduct some tests. One specific host is the (initial) primary host and if the service is stopped or fails on this host it means the test is concluded. Each host has a host_id which is assigned in the inventory and is passed to the service that is running.

However, during execution, the primary host may change according to a list called primary_host_ids.
In this case, the initial primary node is no longer the one that indicates the completion of the test but one of the other nodes within this list with the matching node_id.

In some cases (depending on the settings for this specific test iteration), the test may not conclude within a certain time limit. If that is the case, I also want to stop it and start the next test with the new parameters.

In pseudo-code, this would be:

for every parameter_set in parameter_set_list:
  Extract facts from the parameter_set
  Change configuration files according to the set facts
  Start the service
  Wait for the service to finish on at least one of the potential primary nodes OR for the timeout to occur
  Stop the service
  Fetch some logs

I've written a role to handle the test loop:

# roles/run-tests/main.yml
- name: Loop test
  include_tasks: run-single-test.yml
  loop: "{{ parameter_set_list }}"
  loop_control:
    loop_var: parameter_set

# play.yml
- hosts: all
  name: Loop test role
  roles:
    - name: Run test
      role: run-tests

I've tried various constructs using include_tasks, block, until,delay,retries, etc. but I can't find something that works. Below are some examples of what I tried:

# roles/run-tests/run-single-test.yml
# [...Setup...]
# The following doesn't work because I cannot use `until` with `block`
# Moving the block to its own tasks file also doesn't work because `until`/`delay` cannot be used with `import_tasks` or `include_tasks` either
- name: Wait for completion on at least one primary node
  when: host_id in primary_host_ids
  block:
    - name: Check if service is no longer running
      ansible.builtin.service_facts:
      register: result

    - name: Set end flag
      when: result.ansible_facts.services['myservice.service'].state != "running"
      ansible.builtin.set_fact:
        _primary_completed: true
  until: _primary_completed == true
  retries: 20
  delay: 300
  ignore_errors: true
# [...Cleanup...]

# roles/run-tests/run-single-test.yml
# [...Setup...]
# This loops incorrectly: The retry-until is executed first until completion or timeout and is then iterated over the different IDs
- name: Wait for completion on at least one primary host
  when: item|int == host_id|int
  ansible.builtin.service_facts:
  register: result
  until: result.ansible_facts.services['myservice.service'].state != "running"
  loop: "{{ primary_host_ids }}"
  retries: 20
  delay: 300
  ignore_errors: true
# [...Cleanup...]

# roles/run-tests/run-single-test.yml
# [...Setup...]
# This would wait for the service to complete on *all* potential primary hosts
# I only want to way for *any* of them to complete
- name: Wait for completion on at least one primary host
  when: host_id in primary_host_ids
  ansible.builtin.service_facts:
  register: result
  until: result.ansible_facts.services['myservice.service'].state != "running"
  retries: 20
  delay: 300
  ignore_errors: true
# [...Cleanup...]

If there is no way to do this with just Ansible, is there a way to write a simple Bash script and execute multiple playbooks? I don't really care how ugly this gets but it's important that I find a way to run my tests automatically overnight.

I managed to find a solution with the answer U880D linked

# roles/run-tests/run-single-test.yml
# [...Setup...]
- name: Invalidate finish flag
  ansible.builtin.set_fact:
    experiment_finished: false
  delegate_to: localhost
  delegate_facts: true

- name: Wait for completion on at least one primary node
  when: host_id in primary_host_ids
  block:
    - name: Initialize facts
      ansible.builtin.set_fact:
        tries_max: 20
        tries_counter: 1

    - name: Run check
      ansible.builtin.include_tasks: "./wait-for-completion.yml"


# roles/run-tests/wait-for-completion.yml
---
- name: Get service status
  when: host_id in primary_host_ids
  ansible.builtin.service_facts:
  register: result
  ignore_errors: true

- name: Check if service is completed on primary nodes
  when: 
    - host_id in primary_host_ids
    - result.ansible_facts.services['myservice.service'].state != "running"
  ansible.builtin.set_fact:
    experiment_finished: true
  delegate_to: localhost
  delegate_facts: true

- name: Print result
  when: 
    - host_id in primary_host_ids
  ansible.builtin.debug:
    msg: "{{hostvars['localhost']['experiment_finished']}}"

- name: increase try counter by 1
  ansible.builtin.set_fact:
    tries_counter: "{{ (tries_counter | int) + 1 }}"

- name: Sleep and repeat if service is not completed
  when: 
    - not hostvars['localhost']['experiment_finished']
    - (tries_counter | int) <= (tries_max | int)
    - host_id in primary_host_ids
  block:
    - name: Sleep
      ansible.builtin.pause:
        seconds: "{{ sleep_duration | default(300) }}"

    - name: Run again
      ansible.builtin.include_tasks: "./wait-for-completion.yml"