diff --git a/dags/open_access/open_access.py b/dags/open_access/open_access.py
index a048591..532fc59 100644
--- a/dags/open_access/open_access.py
+++ b/dags/open_access/open_access.py
@@ -66,10 +66,10 @@ def fetch_green_open_access_count(query_object, gold_access, **kwargs):
     )
 
     @task(executor_config=kubernetes_executor_config)
-    def add_year(green_access, **kwargs):
+    def add_year(closed_bronze_gold_green_access, **kwargs):
         year = kwargs["params"].get("year")
-        green_access["year"] = year
-        return green_access
+        closed_bronze_gold_green_access["year"] = year
+        return closed_bronze_gold_green_access
 
     results = add_year(closed_bronze_gold_green_access)