minor worker fix
This commit is contained in:
@@ -47,10 +47,7 @@ export async function incomingEvent(job: Job<EventsQueuePayloadIncomingEvent>) {
|
||||
};
|
||||
|
||||
// this will get the profileId from the alias table if it exists
|
||||
const profileId = await getProfileIdCached({
|
||||
profileId: body.profileId,
|
||||
projectId,
|
||||
});
|
||||
const profileId = body.profileId ?? '';
|
||||
const createdAt = new Date(body.timestamp);
|
||||
const url = getProperty('__path');
|
||||
const { path, hash, query, origin } = parsePath(url);
|
||||
|
||||
@@ -459,6 +459,10 @@ export async function getLastScreenViewFromProfileId({
|
||||
profileId: string;
|
||||
projectId: string;
|
||||
}) {
|
||||
if (!profileId) {
|
||||
return null;
|
||||
}
|
||||
|
||||
const eventInBuffer = await eventBuffer.find(
|
||||
(item) => item.event.profile_id === profileId
|
||||
);
|
||||
|
||||
Reference in New Issue
Block a user