chore(buffer): remove unused deps
This commit is contained in:
@@ -1,7 +1,4 @@
|
||||
import { generateSecureId } from '@openpanel/common/server/id';
|
||||
import { type ILogger, createLogger } from '@openpanel/logger';
|
||||
import { getRedisCache, runEvery } from '@openpanel/redis';
|
||||
import { Prisma } from '@prisma/client';
|
||||
import { runEvery } from '@openpanel/redis';
|
||||
|
||||
import { TABLE_NAMES, ch } from '../clickhouse-client';
|
||||
import { db } from '../prisma-client';
|
||||
|
||||
@@ -1,6 +1,4 @@
|
||||
import { setSuperJson } from '@openpanel/common';
|
||||
import { generateSecureId } from '@openpanel/common/server/id';
|
||||
import { type ILogger as Logger, createLogger } from '@openpanel/logger';
|
||||
import { getRedisCache, getRedisPub, runEvery } from '@openpanel/redis';
|
||||
import { Prisma } from '@prisma/client';
|
||||
import { ch } from '../clickhouse-client';
|
||||
@@ -198,7 +196,8 @@ export class EventBuffer extends BaseBuffer {
|
||||
timer.markAsProcessed = performance.now() - now;
|
||||
|
||||
this.logger.info('Processed events', {
|
||||
count: toInsert.length,
|
||||
inserted: toInsert.length,
|
||||
processed: eventsToProcess.length,
|
||||
timer,
|
||||
});
|
||||
}
|
||||
|
||||
@@ -1,7 +1,5 @@
|
||||
import { createHash } from 'node:crypto';
|
||||
import { generateSecureId } from '@openpanel/common/server/id';
|
||||
import { type ILogger as Logger, createLogger } from '@openpanel/logger';
|
||||
import { getRedisCache, runEvery } from '@openpanel/redis';
|
||||
import { runEvery } from '@openpanel/redis';
|
||||
import { mergeDeepRight } from 'ramda';
|
||||
|
||||
import { TABLE_NAMES, ch, chQuery } from '../clickhouse-client';
|
||||
|
||||
Reference in New Issue
Block a user