diff --git a/apps/worker/src/jobs/events.incoming-event.ts b/apps/worker/src/jobs/events.incoming-event.ts
index 4965acac..6a99c317 100644
--- a/apps/worker/src/jobs/events.incoming-event.ts
+++ b/apps/worker/src/jobs/events.incoming-event.ts
@@ -1,10 +1,6 @@
 import { logger as baseLogger } from '@/utils/logger';
-import {
-  createSessionEndJob,
-  createSessionStart,
-  getSessionEnd,
-} from '@/utils/session-handler';
-import { isSameDomain, parsePath } from '@openpanel/common';
+import { createSessionEndJob, getSessionEnd } from '@/utils/session-handler';
+import { getTime, isSameDomain, parsePath } from '@openpanel/common';
 import {
   getReferrerWithQuery,
   parseReferrer,
@@ -193,7 +189,14 @@ export async function incomingEvent(
 
   if (!sessionEnd) {
     logger.info('Creating session start event', { event: payload });
-    await createSessionStart({ payload }).catch((error) => {
+    await createEventAndNotify(
+      {
+        ...payload,
+        name: 'session_start',
+        createdAt: new Date(getTime(payload.createdAt) - 100),
+      },
+      logger,
+    ).catch((error) => {
       logger.error('Error creating session start event', { event: payload });
       throw error;
     });
diff --git a/apps/worker/src/utils/session-handler.ts b/apps/worker/src/utils/session-handler.ts
index 99af0535..59b6edad 100644
--- a/apps/worker/src/utils/session-handler.ts
+++ b/apps/worker/src/utils/session-handler.ts
@@ -12,18 +12,6 @@ export const SESSION_TIMEOUT = 1000 * 60 * 30;
 const getSessionEndJobId = (projectId: string, deviceId: string) =>
   `sessionEnd:${projectId}:${deviceId}`;
 
-export async function createSessionStart({
-  payload,
-}: {
-  payload: IServiceCreateEventPayload;
-}) {
-  return createEvent({
-    ...payload,
-    name: 'session_start',
-    createdAt: new Date(getTime(payload.createdAt) - 100),
-  });
-}
-
 export async function createSessionEndJob({
   payload,
 }: {