Fix stages in the aggregate pipeline

Author: mikehquan19

uploader/pipelines/trends_course_and_prof_section.go

@@ -6,7 +6,6 @@ import (
 )
 
 var TrendsCourseProfSectionsPipeline = mongo.Pipeline{
-
 	bson.D{
 		{Key: "$lookup",
 			Value: bson.D{
@@ -18,7 +17,7 @@ var TrendsCourseProfSectionsPipeline = mongo.Pipeline{
 		},
 	},
 	bson.D{
-		{Key: "$group",
+		{Key: "$project",
 			Value: bson.D{
 				{Key: "subject_prefix", Value: 1},
 				{Key: "course_number", Value: 1},
@@ -48,7 +47,7 @@ var TrendsCourseProfSectionsPipeline = mongo.Pipeline{
 	bson.D{
 		{Key: "$unwind",
 			Value: bson.D{
-				{Key: "path", Value: "$sections"},
+				{Key: "path", Value: "$professors"},
 				{Key: "preserveNullAndEmptyArrays", Value: false},
 			},
 		},
@@ -63,7 +62,9 @@ var TrendsCourseProfSectionsPipeline = mongo.Pipeline{
 							Value: bson.A{
 								"$subject_prefix",
 								"$course_number",
+								" ",
 								"$professors.first_name",
+								" ",
 								"$professors.last_name",
 							},
 						},

uploader/uploader.go

@@ -65,7 +65,7 @@ func Upload(inDir string, replace bool, staticOnly bool) {
 	buildStaticAggregation(client, ctx, "sections", "events", pipelines.EventsPipeline)
 	buildStaticAggregation(client, ctx, "courses", "trends_course_sections", pipelines.TrendsCourseSectionsPipeline)
 	buildStaticAggregation(client, ctx, "professors", "trends_prof_sections", pipelines.TrendsProfSectionsPipeline)
-	buildStaticAggregation(client, ctx, "courses+professors", "trends_course_and_prof_section", pipelines.TrendsCourseProfSectionsPipeline)
+	buildStaticAggregation(client, ctx, "courses", "trends_course_and_prof_sections", pipelines.TrendsCourseProfSectionsPipeline)
 
 	log.Print("Done building static aggregations!")
 }