--- a/pkg/imports/wx.go	Fri Mar 13 17:34:59 2020 +0100
+++ b/pkg/imports/wx.go	Fri Mar 13 18:04:14 2020 +0100
@@ -25,7 +25,7 @@
 			newConsumer: newSQLConsumer(
 				prepareStmnts(insertWaterwayAxisSQL),
 				consume,
-				createAxisInvalidation(),
+				createAxisInvalidation,
 				newMultiLineFeature(func() interface{} {
 					return new(waterwayAxisProperties)
 				}),
@@ -81,21 +81,19 @@
 `
 )
 
-func createAxisInvalidation() func(*SQLGeometryConsumer) error {
-	return func(spc *SQLGeometryConsumer) error {
-		res, err := spc.tx.ExecContext(spc.ctx, invalidateAxisSQL)
-		if err != nil {
-			return err
-		}
-		old, err := res.RowsAffected()
-		if err != nil {
-			return err
-		}
-		if old == 0 {
-			return ErrFeaturesUnmodified
-		}
-		spc.feedback.Info(
-			"Number of features removed from data source: %d", old)
-		return nil
+func createAxisInvalidation(spc *SQLGeometryConsumer) error {
+	res, err := spc.tx.ExecContext(spc.ctx, invalidateAxisSQL)
+	if err != nil {
+		return err
 	}
+	old, err := res.RowsAffected()
+	if err != nil {
+		return err
+	}
+	if old == 0 {
+		return ErrFeaturesUnmodified
+	}
+	spc.feedback.Info(
+		"Number of features removed from data source: %d", old)
+	return nil
 }