Week 3 QA (#81)

Author: dehume

week_3/tests/test_answer.py

@@ -124,7 +124,8 @@ def test_get_s3_data(stock_list):
 
 
 def test_process_data(stocks):
-    assert process_data(stocks) == Aggregation(date=datetime.datetime(2022, 1, 3, 0, 0), high=12.0)
+    with build_op_context() as context:
+        assert process_data(context, stocks) == Aggregation(date=datetime.datetime(2022, 1, 3, 0, 0), high=12.0)
 
 
 def test_put_redis_data(aggregation):

week_3/workspaces/project/week_3.py

@@ -22,26 +22,31 @@
 
 @op
 def get_s3_data():
+    # You can reuse the logic from the previous week
     pass
 
 
 @op
 def process_data():
+    # You can reuse the logic from the previous week
     pass
 
 
 @op
 def put_redis_data():
+    # You can reuse the logic from the previous week
     pass
 
 
 @op
 def put_s3_data():
+    # You can reuse the logic from the previous week
     pass
 
 
 @graph
 def week_3_pipeline():
+    # You can reuse the logic from the previous week
     pass
 
 

week_4/workspaces/project/week_4.py

@@ -7,21 +7,25 @@
 
 @asset
 def get_s3_data():
+    # You can reuse the logic from the previous week
     pass
 
 
 @asset
 def process_data():
+    # You can reuse the logic from the previous week
     pass
 
 
 @asset
 def put_redis_data():
+    # You can reuse the logic from the previous week
     pass
 
 
 @asset
 def put_s3_data():
+    # You can reuse the logic from the previous week
     pass