use the new utility to slap extra metadata to retries

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

diff --git a/radosgw_agent/worker.py b/radosgw_agent/worker.py
index 917e8f6753cb9b4048636731d2f2783c97c9e287..4d01cc93dedb03d352d8c505c47c3912490683d0 100644 (file)
--- a/radosgw_agent/worker.py
+++ b/radosgw_agent/worker.py
@@ -8,6 +8,7 @@ import time
 
 from radosgw_agent import client
 from radosgw_agent import lock
+from radosgw_agent.util import obj
 from radosgw_agent.exceptions import SkipShard, SyncError, SyncTimedOut, SyncFailed, NotFound, BucketEmpty
 from radosgw_agent.constants import DEFAULT_TIME, RESULT_SUCCESS, RESULT_ERROR
 
@@ -73,7 +74,9 @@ class Worker(multiprocessing.Process):
             if type_ is None:
                 type_ = self.type
             try:
-                data = [dict(name=item, time=DEFAULT_TIME) for item in retries]
+                data = [
+                    obj.to_dict(item, time=DEFAULT_TIME) for item in retries
+                ]
                 client.set_worker_bound(self.dest_conn,
                                         type_,
                                         marker,
@@ -302,7 +305,7 @@ class DataWorker(Worker):
             except SyncError as err:
                 log.error('failed to sync object %s/%s: %s',
                           bucket, obj.name, err)
-                retry_objs.append(obj.name)
+                retry_objs.append(obj)
 
         log.debug('bucket {bucket} has {num_objects} object'.format(
                   bucket=bucket, num_objects=count))