diff --git a/jetstream.ts b/jetstream.ts index 8958564..56df8be 100644 --- a/jetstream.ts +++ b/jetstream.ts @@ -72,6 +72,9 @@ const flushBulkCreate = async (did: string): Promise => { if (!buffer) return; bulkBuffers.delete(did); const webhooks = getWebhooksByDidAndVerb(did, "bulk-create"); + log( + `[jetstream] bulk-create ${did}: ${buffer.records.length} record(s)`, + ); await dispatchAll( webhooks, { event: "bulk-create", did, records: buffer.records },