from radosgw_agent import client
from radosgw_agent import lock
from radosgw_agent.exceptions import SkipShard, SyncError, SyncTimedOut, SyncFailed, NotFound, BucketEmpty
+from radosgw_agent.constants import DEFAULT_TIME, RESULT_SUCCESS, RESULT_ERROR
log = logging.getLogger(__name__)
-RESULT_SUCCESS = 0
-RESULT_ERROR = 1
-
-DEFAULT_TIME = '1970-01-01 00:00:00'
class Worker(multiprocessing.Process):
"""sync worker to run in its own process"""