From: Oguzhan Ozmen <oozmen@bloomberg.net>
Date: Mon, 24 Nov 2025 03:09:53 +0000 (+0000)
Subject: RGW/test_multi: add a helper function to get data sync oldest incremental change
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=c97d61c5c7b71daee3fd8beca6b5de2304adff76;p=ceph-ci.git

RGW/test_multi: add a helper function to get data sync oldest incremental change

Signed-off-by: Oguzhan Ozmen <oozmen@bloomberg.net>
---

diff --git a/src/test/rgw/rgw_multi/tests.py b/src/test/rgw/rgw_multi/tests.py
index e364b45f8f6..d1ceddba4ea 100644
--- a/src/test/rgw/rgw_multi/tests.py
+++ b/src/test/rgw/rgw_multi/tests.py
@@ -1,5 +1,6 @@
 import json
 import random
+import re
 import string
 import time
 import logging
@@ -425,6 +426,16 @@ def zonegroup_bucket_checkpoint(zonegroup_conns, bucket_name):
         if target_conn.zone.has_buckets():
             target_conn.check_bucket_eq(source_conn, bucket_name)
 
+def get_oldest_incremental_change_not_applied_epoch(zone):
+    cmd = ['sync', 'status']
+    sync_status_output, retcode = zone.cluster.admin(cmd, check_retcode=False, read_only=True)
+    assert(retcode == 0)
+    match = re.search(r"oldest incremental change not applied:\s*([0-9T:\.\+\-Z]+)", sync_status_output)
+    timestamp = match.group(1) if match else None
+    if timestamp is not None:
+        timestamp = datetime.strptime(timestamp, "%Y-%m-%dT%H:%M:%S.%f%z").timestamp()
+    return timestamp
+
 def set_master_zone(zone):
     zone.modify(zone.cluster, ['--master'])
     zonegroup = zone.zonegroup