Move retry delay parsing to notification processor

Author: Sergiu Ghitea

driver/sql/projection_notification_processor.go

@@ -53,6 +53,10 @@ func newBackgroundProcessor(
 		metrics = NopMetrics
 	}
 
+	if retryDelay == 0 {
+		retryDelay = time.Millisecond * 50
+	}
+
 	return &projectionNotificationProcessor{
 		queueProcessors: queueProcessors,
 		queueBuffer:     queueBuffer,

driver/sql/projector_aggregate.go

@@ -78,13 +78,6 @@ func NewAggregateProjector(
 		return nil, err
 	}
 
-	if retryDelay == 0 {
-		retryDelay, err = time.ParseDuration("50ms")
-		if err != nil {
-			return nil, err
-		}
-	}
-
 	return &AggregateProjector{
 		backgroundProcessor:    processor,
 		executor:               executor,