feat(cdp): batch hogfun watcher

[meikelmosby]

Problem

Because we do not want to run getStates per Event or just using a percentage of our traffic we perform the operation using hogwatcher per batch

Changes

• implemented saving hogwatcher-state on hogtransformer class
• filtering (currently only logging) out of functions that are degraded
• added instrumentation for added latency of hogwatcher operations (redis calls)
• added function to get hogfunctionIds for a Team

👉 Stay up-to-date with PostHog coding conventions for a smoother review.

How did you test this code?

• added new tests

[posthog-bot]

Hey @meikelmosby! 👋
This pull request seems to contain no description. Please add useful context, rationale, and/or any other information that will help make sense of this change now and in the distant Mars-based future.

[greptile-apps]

PR Summary

This PR refactors the ingestion pipeline to support batch processing of Hog functions and their watcher states, reducing per-event overhead.

• Updated plugin-server/src/worker/ingestion/event-pipeline/runner.ts to accept a new teamHogFunctions parameter and aggregate watcher promises.
• Modified plugin-server/src/ingestion/ingestion-consumer.ts to prefetch and filter Hog functions in batches using hogWatcher states.
• Refactored plugin-server/src/cdp/hog-transformations/hog-transformer.service.ts to simplify transformation logic and accept team hog functions.
• Aligned plugin-server/src/worker/ingestion/event-pipeline/transformEventStep.ts to maintain consistent watcherPromises output.

_{4 file(s) reviewed, no comment(s)
Edit PR Review Bot Settings | Greptile}

[benjackwhite]

Small change request otherwise looks good