fix applyColumnCasingToDf ds.CurrentBatch

slingdata-io · Oct 24, 2024 · d7d1149 · d7d1149
1 parent 3cf0bf2
commit d7d1149
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/sling/task.go b/core/sling/task.go
@@ -420,8 +420,10 @@ func applyColumnCasingToDf(df *iop.Dataflow, connType dbio.Type, casing *iop.Col
 			ds.Columns[i].Name = casing.Apply(col.Name, connType)
 		}
 
-		for i, col := range ds.CurrentBatch.Columns {
-			ds.CurrentBatch.Columns[i].Name = casing.Apply(col.Name, connType)
+		if ds.CurrentBatch != nil {
+			for i, col := range ds.CurrentBatch.Columns {
+				ds.CurrentBatch.Columns[i].Name = casing.Apply(col.Name, connType)
+			}
 		}
 	}
 }