Function FromTaskToDatasetShard

flow/context.go:172–176

(task *Task, shard *DatasetShard)

}

func FromTaskToDatasetShard(task *Task, shard *DatasetShard) {
	if shard != nil {
		task.Outputs = append(task.Outputs, shard)
	}
}