.

echo-side/dags/process_new_zips.py

@@ -51,7 +51,7 @@ def print_bucket_name(bucket_name):
             task_id=f'print_bucket_name_{bucket_name}',
             python_callable=print_bucket_name,
             op_kwargs={'bucket_name': bucket_name},
-        ) for bucket_name in "{{ task_instance.xcom_pull(task_ids='get_bucket_names', key='bucket_names') }}"]
+        ) for bucket_name in "{{ xcom_pull(task_ids='get_bucket_names', key='bucket_names') }}"]
 
     # if len(bucket_names) > 0:
     #     print(f'Bucket names found: {bucket_names}')