diff --git a/config/celery.py b/config/celery.py
index f1687b2..1d6bee0 100644
--- a/config/celery.py
+++ b/config/celery.py
@@ -2,10 +2,13 @@
 Celery configuration for KeepItGoing.
 """
 
+import logging
 import os
 from celery import Celery
 from celery.schedules import crontab
 
+logger = logging.getLogger(__name__)
+
 # Set the default Django settings module
 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'config.settings')
 
@@ -32,4 +35,4 @@ app.conf.beat_schedule = {
 
 @app.task(bind=True)
 def debug_task(self):
-    print(f'Request: {self.request!r}')
+    logger.debug(f'Request: {self.request!r}')
diff --git a/notifications/tasks.py b/notifications/tasks.py
index 744c546..ffe8ca0 100644
--- a/notifications/tasks.py
+++ b/notifications/tasks.py
@@ -2,10 +2,13 @@
 Celery tasks for notifications.
 """
 
+import logging
 from celery import shared_task
 from django.utils import timezone
 from datetime import timedelta
 
+logger = logging.getLogger(__name__)
+
 
 @shared_task
 def send_due_reminders():
@@ -157,7 +160,7 @@ def send_fcm_notification(token, title, body, data=None):
 
     except Exception as e:
         # Log error but don't fail
-        print(f"FCM notification failed: {e}")
+        logger.error(f"FCM notification failed: {e}")
 
 
 @shared_task
@@ -187,7 +190,7 @@ def send_web_push_notification(subscription_info, title, body, data=None):
         )
 
     except Exception as e:
-        print(f"Web push notification failed: {e}")
+        logger.error(f"Web push notification failed: {e}")
 
 
 @shared_task
diff --git a/sync/views.py b/sync/views.py
index 5d3bd1a..c466c7e 100644
--- a/sync/views.py
+++ b/sync/views.py
@@ -4,6 +4,7 @@ Sync views for KeepItGoing.
 Handles data synchronization between clients and server.
 """
 
+import logging
 import uuid
 from datetime import datetime
 from django.utils import timezone
@@ -25,6 +26,8 @@ from tasks.serializers import (
 from .models import SyncLog, SyncConflict
 from .serializers import SyncConflictSerializer
 
+logger = logging.getLogger(__name__)
+
 
 @api_view(['POST'])
 @permission_classes([IsAuthenticated])
@@ -64,7 +67,7 @@ def sync(request):
     # Debug logging
     task_changes = changes.get('tasks', [])
     deleted_task_count = sum(1 for t in task_changes if t.get('is_deleted', False))
-    print(f"[SERVER SYNC DEBUG] Received sync request with {len(task_changes)} tasks, {deleted_task_count} marked as deleted")
+    logger.debug(f"Received sync request with {len(task_changes)} tasks, {deleted_task_count} marked as deleted")
 
     if not device_id:
         return Response(
@@ -122,17 +125,17 @@ def process_task_changes(user, task_changes, last_sync_at):
 
         # Debug logging
         if is_deleted:
-            print(f"[SERVER SYNC DEBUG] Received deletion for task sync_id: {sync_id}")
+            logger.debug(f"Received deletion for task sync_id: {sync_id}")
 
         try:
             existing = Task.all_objects.get(sync_id=sync_id, user=user)
 
             if is_deleted:
                 # Soft delete the task
-                print(f"[SERVER SYNC DEBUG] Soft deleting task: {existing.title} (id: {existing.id})")
+                logger.debug(f"Soft deleting task: {existing.title} (id: {existing.id})")
                 existing.is_deleted = True
                 existing.save()
-                print(f"[SERVER SYNC DEBUG] Task soft deleted successfully")
+                logger.debug(f"Task soft deleted successfully")
                 continue
 
             # Check for conflict
@@ -212,12 +215,12 @@ def process_time_entry_changes(user, entry_changes, last_sync_at):
     """Process time entry changes from client."""
     conflicts = []
 
-    print(f"[SERVER SYNC DEBUG] Processing {len(entry_changes)} time entry changes")
+    logger.debug(f"Processing {len(entry_changes)} time entry changes")
 
     for entry_data in entry_changes:
         sync_id = entry_data.get('sync_id')
         is_deleted = entry_data.get('is_deleted', False)
-        print(f"[SERVER SYNC DEBUG] Time entry sync_id: {sync_id}, is_deleted: {is_deleted}")
+        logger.debug(f"Time entry sync_id: {sync_id}, is_deleted: {is_deleted}")
 
         try:
             existing = TimeEntry.all_objects.get(sync_id=sync_id, user=user)
@@ -254,8 +257,8 @@ def process_time_entry_changes(user, entry_changes, last_sync_at):
         except TimeEntry.DoesNotExist:
             if not is_deleted:
                 task_sync_id = entry_data.get('task_sync_id')
-                print(f"[SERVER SYNC DEBUG] Creating new time entry for task_sync_id: {task_sync_id}")
-                print(f"[SERVER SYNC DEBUG]   started_at: {entry_data.get('started_at')}, ended_at: {entry_data.get('ended_at')}")
+                logger.debug(f"Creating new time entry for task_sync_id: {task_sync_id}")
+                logger.debug(f"  started_at: {entry_data.get('started_at')}, ended_at: {entry_data.get('ended_at')}")
                 try:
                     task = Task.objects.get(sync_id=task_sync_id, user=user)
 
@@ -276,9 +279,9 @@ def process_time_entry_changes(user, entry_changes, last_sync_at):
                         ended_at=ended_at,
                         notes=entry_data.get('notes', ''),
                     )
-                    print(f"[SERVER SYNC DEBUG] Created time entry: {new_entry.id}, duration_seconds: {new_entry.duration_seconds}")
+                    logger.debug(f"Created time entry: {new_entry.id}, duration_seconds: {new_entry.duration_seconds}")
                 except Task.DoesNotExist:
-                    print(f"[SERVER SYNC DEBUG] Task not found for sync_id: {task_sync_id}")
+                    logger.debug(f"Task not found for sync_id: {task_sync_id}")
                     pass  # Skip if task doesn't exist
 
     return conflicts
@@ -348,7 +351,7 @@ def create_task_from_data(user, data):
 
 def get_server_changes(user, last_sync_at):
     """Get all changes on server since last sync."""
-    print(f"[SERVER SYNC DEBUG] get_server_changes: last_sync_at={last_sync_at}")
+    logger.debug(f"get_server_changes: last_sync_at={last_sync_at}")
     filter_kwargs = {'user': user}
 
     # For incremental sync, filter by updated_at
@@ -364,11 +367,11 @@ def get_server_changes(user, last_sync_at):
         tags = Tag.all_objects.filter(user=user)
         time_entries = TimeEntry.all_objects.filter(user=user)
 
-    print(f"[SERVER SYNC DEBUG] Returning {len(tasks)} tasks, {len(tags)} tags, {len(time_entries)} time entries")
+    logger.debug(f"Returning {len(tasks)} tasks, {len(tags)} tags, {len(time_entries)} time entries")
     if time_entries:
-        print(f"[SERVER SYNC DEBUG] Time entries being sent to client:")
+        logger.debug(f"Time entries being sent to client:")
         for entry in time_entries:
-            print(f"[SERVER SYNC DEBUG]   sync_id: {entry.sync_id}, task: {entry.task.title}, duration: {entry.duration_seconds}s, updated_at: {entry.updated_at}")
+            logger.debug(f"  sync_id: {entry.sync_id}, task: {entry.task.title}, duration: {entry.duration_seconds}s, updated_at: {entry.updated_at}")
 
     return {
         'tasks': TaskSyncSerializer(tasks, many=True).data,
diff --git a/tasks/views.py b/tasks/views.py
index fcc07c0..c752220 100644
--- a/tasks/views.py
+++ b/tasks/views.py
@@ -2,6 +2,7 @@
 Task views for KeepItGoing.
 """
 
+import logging
 from django.contrib.auth.decorators import login_required
 from django.db.models import Q
 from django.shortcuts import render, redirect, get_object_or_404
@@ -22,6 +23,8 @@ from .serializers import (
     TaskShareSerializer,
 )
 
+logger = logging.getLogger(__name__)
+
 
 # =============================================================================
 # API Views
@@ -553,7 +556,7 @@ def task_detail_partial(request, task_id):
 def web_timer_start(request, task_id):
     """Start a timer for a task (web view)."""
     task = get_object_or_404(Task, id=task_id, user=request.user)
-    print(f"[WEB TIMER DEBUG] Starting timer for task: {task.title} (id: {task_id})")
+    logger.debug(f"Starting timer for task: {task.title} (id: {task_id})")
 
     # Stop any existing running timer first (properly to calculate duration)
     running_entries = TimeEntry.objects.filter(
@@ -567,7 +570,7 @@ def web_timer_start(request, task_id):
         entry.save()  # This will calculate duration_seconds
         stopped_count += 1
 
-    print(f"[WEB TIMER DEBUG] Stopped {stopped_count} existing timers")
+    logger.debug(f"Stopped {stopped_count} existing timers")
 
     # Create new timer
     entry = TimeEntry.objects.create(
@@ -575,7 +578,7 @@ def web_timer_start(request, task_id):
         user=request.user,
         started_at=timezone.now()
     )
-    print(f"[WEB TIMER DEBUG] Created new timer entry: {entry.id}")
+    logger.debug(f"Created new timer entry: {entry.id}")
 
     next_url = request.POST.get('next', 'dashboard')
     return redirect(next_url)
@@ -585,7 +588,7 @@ def web_timer_start(request, task_id):
 @require_POST
 def web_timer_stop(request, task_id):
     """Stop a timer for a task (web view)."""
-    print(f"[WEB TIMER DEBUG] Stopping timer for task_id: {task_id}")
+    logger.debug(f"Stopping timer for task_id: {task_id}")
 
     # Get the running timer and stop it properly (to trigger save() and calculate duration)
     entries = TimeEntry.objects.filter(
@@ -600,7 +603,7 @@ def web_timer_stop(request, task_id):
         entry.save()  # This will calculate duration_seconds
         stopped_count += 1
 
-    print(f"[WEB TIMER DEBUG] Stopped {stopped_count} timer entries")
+    logger.debug(f"Stopped {stopped_count} timer entries")
 
     next_url = request.POST.get('next', 'dashboard')
     return redirect(next_url)