diff --git a/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts b/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts
index 0c17580825565..995b2eeae2667 100644
--- a/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts
+++ b/plugin-server/tests/cdp/cdp-internal-events-consumer.test.ts
@@ -24,12 +24,12 @@ describe('CDP Internal Events Consumer', () => {
         team = await getFirstTeam(hub)
 
         processor = new CdpInternalEventsConsumer(hub)
-        await processor.start()
+        // Speed hack as we don't need all of kafka to be started for this test
+        await processor.hogFunctionManager.start(processor['hogTypes'])
     })
 
     afterEach(async () => {
-        jest.setTimeout(10000)
-        await processor.stop()
+        jest.setTimeout(1000)
         await closeHub(hub)
     })
 
diff --git a/posthog/api/test/test_hog_function_templates.py b/posthog/api/test/test_hog_function_templates.py
index eeaec1beaf945..4a34e36f88235 100644
--- a/posthog/api/test/test_hog_function_templates.py
+++ b/posthog/api/test/test_hog_function_templates.py
@@ -68,7 +68,7 @@ def test_filter_function_templates(self):
 
     def test_filter_sub_templates(self):
         response1 = self.client.get(
-            "/api/projects/@current/hog_function_templates/?type=internal_destination&sub_template_id=activity_log"
+            "/api/projects/@current/hog_function_templates/?type=internal_destination&sub_template_id=activity-log"
         )
         assert response1.status_code == status.HTTP_200_OK, response1.json()
         assert len(response1.json()["results"]) > 0