code: def remove_existing_container(engine_obj, service_name, remove_volumes=False):
      
      conductor_container_id = engine_obj.get_container_id_for_service(service_name)
      if engine_obj.service_is_running(service_name):
          engine_obj.stop_container(conductor_container_id, forcefully=True)
      if conductor_container_id:
          engine_obj.delete_container(conductor_container_id, remove_volumes=remove_volumes)
docs: Remove a container for an existing service. Handy for removing an existing conductor.