diff --git a/core/utils/waveform.py b/core/utils/waveform.py
index 106f5ca..bd7b4a9 100755
--- a/core/utils/waveform.py
+++ b/core/utils/waveform.py
@@ -1,7 +1,5 @@
-import subprocess
-import traceback
-import uuid
 import os
+
 from dss import settings
 
 
diff --git a/spa/tasks.py b/spa/tasks.py
index 5a7f739..65bd081 100755
--- a/spa/tasks.py
+++ b/spa/tasks.py
@@ -4,7 +4,6 @@ import logging
 import json
 import requests
 from core.realtime import activity
-
 from core.utils import cdn
 from spa.models import Mix
 from spa.signals import waveform_generated_signal
@@ -63,7 +62,9 @@ def update_geo_info_task(ip_address, profile_id):
 @task
 def notify_subscriber(session_id, uid):
     if session_id is not None:
-        activity.post_activity('user:process', session_id, {'type': 'waveform', 'target': uid})
+        message = {'type': 'waveform', 'target': uid}
+        logger.info("Tasks: notifying user:process. Session: {} Message: {}".format(session_id, message))
+        activity.post_activity('user:process', message=message, session=session_id)
 
 
 @task