Ceph » Orchestrator

The cephadm module, while applying service specs, creates a progress event for the daemons to be added or deleted from the hosts. The progress event is initialized if progress_total is greater than 0 (`progress_total = len(slots_to_add) + len(daemons_to_remove)`) but at the end tries to mark the progress event as complete/fail even though progress event has not been initialized. This creates a noise in the mgr logs with "[progress WARNING root] complete: ev {UUID} does not exist" messages.

cephadm/serve.py code :
- Initialize the progress event in case daemons to be added or deleted from hosts :

        # progress
        progress_id = str(uuid.uuid4())
        delta: List[str] = []
        if slots_to_add:
            delta += [f'+{len(slots_to_add)}']
        if daemons_to_remove:
            delta += [f'-{len(daemons_to_remove)}']
        progress_title = f'Updating {spec.service_name()} deployment ({" ".join(delta)} -> {len(all_slots)})'
        progress_total = len(slots_to_add) + len(daemons_to_remove)
        progress_done = 0

        def update_progress() -> None:
            self.mgr.remote(
                'progress', 'update', progress_id,
                ev_msg=progress_title,
                ev_progress=(progress_done / progress_total),
                add_to_ceph_s=True,
            )

        if progress_total:
            update_progress()

Mark a progress event complete or fail :

...
            self.mgr.remote('progress', 'complete', progress_id)
        except Exception as e:
            self.mgr.remote('progress', 'fail', progress_id, str(e))
            raise
        finally:
...