mirrors/posthog
0
0
Fork 0
mirror of https://github.com/PostHog/posthog.git synced 2024-12-01 04:12:23 +01:00
Code Issues Releases Activity

fix: maybe not awaiting (#15667)

Browse Source
This commit is contained in:
Paul D'Ambra 2023-05-23 12:00:17 +01:00 committed by GitHub
parent b35dfc93e6
commit 62b69e90aa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin-server/src/main/ingestion-queues/session-recording/session-recordings-blob-consumer.ts
View File

@ -345,7 +345,7 @@ export class SessionRecordingBlobIngester {
this.flushInterval = setTimeout(() => this.checkEachSession(), flushIntervalTimeoutMs)
}
private async checkEachSession() {
private checkEachSession() {
let sessionManagerBufferSizes = 0
for (const [_, sessionManager] of this.sessions) {
@ -361,7 +361,7 @@ export class SessionRecordingBlobIngester {
this.serverConfig.SESSION_RECORDING_MAX_BUFFER_AGE_MULTIPLIER
)
await sessionManager.flushIfSessionBufferIsOld(kafkaNow, flushThresholdMillis).catch((err) => {
void sessionManager.flushIfSessionBufferIsOld(kafkaNow, flushThresholdMillis).catch((err) => {
status.error(
'🚽',
'blob_ingester_consumer - failed trying to flush on idle session: ' + sessionManager.sessionId,