worker will now use the new get_worker_bound values

Signed-off-by: Alfredo Deza <adeza@redhat.com>

diff --git a/radosgw_agent/worker.py b/radosgw_agent/worker.py
index 8731f50926ecc48fd4ea67a461657e6861c8647b..9e9eec898796a034f47546f42106f10e30314bbd 100644 (file)
--- a/radosgw_agent/worker.py
+++ b/radosgw_agent/worker.py
@@ -311,15 +311,15 @@ class DataWorkerIncremental(IncrementalMixin, DataWorker):
 
         new_retries = []
         for bucket_instance in bucket_instances.union(retries):
-            try:
-                marker, timestamp, retries = client.get_worker_bound(
-                    self.dest_conn,
-                    'bucket-index',
-                    bucket_instance)
-            except NotFound:
-                log.debug('no worker bound found for bucket instance "%s"',
-                          bucket_instance)
-                marker, timestamp, retries = ' ', DEFAULT_TIME, []
+            bound = client.get_worker_bound(
+                self.dest_conn,
+                'bucket-index',
+                bucket_instance)
+
+            marker = bound['marker']
+            retries = bound['retries']
+            timestamp = bound['oldest_time']
+
             try:
                 sync_result = self.inc_sync_bucket_instance(bucket_instance,
                                                             marker,