WIP

Author: tellet-q

ansible/playbooks/files/transfer-speed/docker-compose-cluster.yaml

@@ -16,4 +16,4 @@ services:
     volumes:
       - ./qdrant_data:/qdrant/storage
     command: >
-      sh -c "./qdrant ${CLUSTER_BOOTSTRAP_URI:+--uri $CLUSTER_BOOTSTRAP_URI}"
+      sh -c "./qdrant --uri '${NODE_URI}' ${BOOTSTRAP_URI:+--bootstrap '${BOOTSTRAP_URI}'}"

ansible/playbooks/playbook-transfer-speed.yml

@@ -7,9 +7,10 @@
     - name: Load variables
       include_vars: "group_vars/transfer-speed.yml"
 
-    - name: Set bootstrap URI for non-first nodes
+    - name: Set cluster URIs
       set_fact:
-        cluster_bootstrap_uri: "{{ 'http://' + hostvars[groups['remote_machines'][0]]['ansible_host'] + ':6335' if inventory_hostname != groups['remote_machines'][0] else '' }}"
+        node_uri: "http://{{ ansible_host }}:6335"
+        bootstrap_uri: "{{ '' if inventory_hostname == groups['remote_machines'][0] else 'http://' + hostvars[groups['remote_machines'][0]]['ansible_host'] + ':6335' }}"
 
     - name: Setup Qdrant cluster node
       include_role:

ansible/playbooks/roles/setup-qdrant-cluster/tasks/main.yml

@@ -16,10 +16,13 @@
 
 - name: Stop existing containers
   ansible.builtin.shell: |
-    docker compose down || true
-    docker rm -f qdrant-node || true
-  args:
-    chdir: "{{ working_dir }}"
+    cd {{ working_dir }} && docker compose down 2>/dev/null || true
+    docker rm -f qdrant-node 2>/dev/null || true
+    docker rm -f qdrant-continuous 2>/dev/null || true
+    # Kill any container using port 6333
+    docker ps -q --filter "publish=6333" | xargs -r docker rm -f 2>/dev/null || true
+    # Also remove the data directory to ensure clean state
+    rm -rf {{ working_dir }}/qdrant_data || true
   ignore_errors: yes
 
 - name: Remove old image to ensure fresh pull
@@ -35,7 +38,8 @@
   environment:
     QDRANT_VERSION: "{{ server_version }}"
     CONTAINER_REGISTRY: "{{ server_registry }}"
-    CLUSTER_BOOTSTRAP_URI: "{{ cluster_bootstrap_uri | default('') }}"
+    NODE_URI: "{{ node_uri }}"
+    BOOTSTRAP_URI: "{{ bootstrap_uri | default('') }}"
     QDRANT__FEATURE_FLAGS__ALL: "{{ feature_flags | default('false') }}"
   register: compose_result
   failed_when: compose_result.rc != 0
@@ -46,7 +50,7 @@
     status_code: 200
   register: result
   until: result.status == 200
-  retries: 60
+  retries: 10
   delay: 2
 
 - name: Wait for node to join cluster
@@ -56,6 +60,6 @@
     return_content: yes
   register: cluster_status
   until: cluster_status.json.result.peer_id is defined
-  retries: 30
+  retries: 10
   delay: 2
-  when: cluster_bootstrap_uri | default('') != ''
+  when: bootstrap_uri | default('') != ''