diff --git a/scouter/activities/activities.py b/scouter/activities/activities.py
index 4100f85..fd1edb0 100644
--- a/scouter/activities/activities.py
+++ b/scouter/activities/activities.py
@@ -63,5 +63,5 @@ class Activities(Postgres, Redis, Kafka, Gates):
         )
 
     @activity.defn(name="prepare_activity")
-    def prepare_activity(self, input_data: dict[str, Any]):
+    async def prepare_activity(self, input_data: dict[str, Any]):
         super().prepare_activity(input_data)
diff --git a/scouter/activities/base.py b/scouter/activities/base.py
index 7269d41..3adb0e4 100644
--- a/scouter/activities/base.py
+++ b/scouter/activities/base.py
@@ -10,7 +10,7 @@ class BaseActivity:
         self.notification_handler = notification_handler
 
     @activity.defn(name="prepare_activity")
-    def prepare_activity(self, input_data: dict[str, Any]):
+    async def prepare_activity(self, input_data: dict[str, Any]):
         """
         Prepare the activity for the notification handler.