Faster reconcile in case of err in fetch realtime

alok87 · alok87 · commit d799fff28728 · 2021-02-18T22:05:20.000+05:30
Hopefull fixes
diff --git a/controllers/redshiftsink_controller.go b/controllers/redshiftsink_controller.go
@@ -417,7 +417,8 @@ func (r *RedshiftSinkReconciler) reconcile(
 
 	currentRealtime, err := reload.realtimeTopics(kafkaWatcher)
 	if err != nil {
-		return result, nil, err
+		return resultRequeueMilliSeconds(1), nil, fmt.Errorf(
+			"Error fetching realtime stats for: %v, err: %v", rsk.Name, err)
 	}
 	if !subSetSlice(currentRealtime, status.realtime) {
 		for _, moreRealtime := range currentRealtime {

Original file line number	Diff line number	Diff line change
`@@ -417,7 +417,8 @@ func (r *RedshiftSinkReconciler) reconcile(`
`417`	`417`
`418`	`418`	`currentRealtime, err := reload.realtimeTopics(kafkaWatcher)`
`419`	`419`	`if err != nil {`
`420`		`- return result, nil, err`
	`420`	`+ return resultRequeueMilliSeconds(1), nil, fmt.Errorf(`
	`421`	`+ "Error fetching realtime stats for: %v, err: %v", rsk.Name, err)`
`421`	`422`	`}`
`422`	`423`	`if !subSetSlice(currentRealtime, status.realtime) {`
`423`	`424`	`for _, moreRealtime := range currentRealtime {`