change imports

apps/worker/src/jobs/cron.ts

@@ -1,7 +1,7 @@
 import type { Job } from 'bullmq';
 
 import { eventBuffer, profileBuffer } from '@openpanel/db';
-import type { CronQueuePayload } from '@openpanel/queue/src/queues';
+import type { CronQueuePayload } from '@openpanel/queue';
 
 import { salt } from './cron.salt';
 

apps/worker/src/jobs/events.create-session-end.ts

@@ -2,7 +2,7 @@ import type { Job } from 'bullmq';
 
 import { getTime } from '@openpanel/common';
 import { createEvent, eventBuffer, getEvents } from '@openpanel/db';
-import type { EventsQueuePayloadCreateSessionEnd } from '@openpanel/queue/src/queues';
+import type { EventsQueuePayloadCreateSessionEnd } from '@openpanel/queue';
 
 export async function createSessionEnd(
   job: Job<EventsQueuePayloadCreateSessionEnd>

apps/worker/src/jobs/events.incoming-event.ts

@@ -9,12 +9,11 @@ import { getTime, toISOString } from '@openpanel/common';
 import type { IServiceCreateEventPayload } from '@openpanel/db';
 import { createEvent } from '@openpanel/db';
 import { getLastScreenViewFromProfileId } from '@openpanel/db/src/services/event.service';
-import { findJobByPrefix } from '@openpanel/queue';
-import { eventsQueue, sessionsQueue } from '@openpanel/queue/src/queues';
+import { eventsQueue, findJobByPrefix, sessionsQueue } from '@openpanel/queue';
 import type {
   EventsQueuePayloadCreateSessionEnd,
   EventsQueuePayloadIncomingEvent,
-} from '@openpanel/queue/src/queues';
+} from '@openpanel/queue';
 import { redis } from '@openpanel/redis';
 
 function noDateInFuture(eventDate: Date): Date {

apps/worker/src/jobs/events.ts

@@ -6,7 +6,7 @@ import type {
   EventsQueuePayload,
   EventsQueuePayloadCreateSessionEnd,
   EventsQueuePayloadIncomingEvent,
-} from '@openpanel/queue/src/queues';
+} from '@openpanel/queue';
 
 import { createSessionEnd } from './events.create-session-end';
 import { incomingEvent } from './events.incoming-event';

apps/worker/src/jobs/sessions.ts

@@ -1,6 +1,6 @@
 import type { Job } from 'bullmq';
 
-import type { SessionsQueuePayload } from '@openpanel/queue/src/queues';
+import type { SessionsQueuePayload } from '@openpanel/queue';
 
 import { createSessionEnd } from './events.create-session-end';