diff --git a/workers/storagereplication.py b/workers/storagereplication.py
index be000884d..767daf203 100644
--- a/workers/storagereplication.py
+++ b/workers/storagereplication.py
@@ -10,6 +10,7 @@ from workers.queueworker import QueueWorker, WorkerUnhealthyException
 logger = logging.getLogger(__name__)
 
 POLL_PERIOD_SECONDS = 10
+RESERVATION_SECONDS = app.config.get('STORAGE_REPLICATION_PROCESSING_SECONDS', 60*20)
 
 class StorageReplicationWorker(QueueWorker):
   def process_queue_item(self, job_details):
@@ -97,5 +98,6 @@ if __name__ == "__main__":
 
   logger.debug('Starting replication worker')
   worker = StorageReplicationWorker(image_replication_queue,
-                                    poll_period_seconds=POLL_PERIOD_SECONDS)
+                                    poll_period_seconds=POLL_PERIOD_SECONDS,
+                                    reservation_seconds=RESERVATION_SECONDS)
   worker.start()