add a print

breathecode/activity/tasks.py

@@ -1,26 +1,30 @@
-from datetime import date, datetime, timedelta
 import functools
+import logging
+import os
 import pickle
-import logging, os
 import re
-from typing import Optional
 import uuid
-from celery import shared_task
+from datetime import date, datetime, timedelta
+from typing import Optional
+
 import zstandard
+from celery import shared_task
+from django.core.cache import cache
+from django.utils import timezone
+from django_redis import get_redis_connection
+from google.cloud import bigquery
+from redis.exceptions import LockError
+
 from breathecode.activity import actions
 from breathecode.admissions.models import Cohort, CohortUser
 from breathecode.admissions.utils.cohort_log import CohortDayLog
 from breathecode.services.google_cloud.big_query import BigQuery
-from breathecode.utils.decorators import task, AbortTask, TaskPriority, RetryTask
-from .models import StudentActivity
 from breathecode.utils import NDB
-from django.utils import timezone
-from google.cloud import bigquery
-from django.core.cache import cache
-from django_redis import get_redis_connection
-from redis.exceptions import LockError
+from breathecode.utils.decorators import AbortTask, RetryTask, TaskPriority, task
 from breathecode.utils.redis import Lock
 
+from .models import StudentActivity
+
 
 @functools.lru_cache(maxsize=1)
 def get_activity_sampling_rate():
@@ -272,6 +276,8 @@ def extract_data():
 
     try:
         if new_schema:
+            print('updating schema', schema)
+            print('updating schema', new_schema)
             table.update_schema(new_schema, append=True)
 
         table.bulk_insert(rows)