Flyte enables production-grade orchestration for machine learning workflows and data processing created to accelerate local workflows to production.

Flyte

<https://github.com/flyteorg/flyte/pull/6987|#6987 Add OppoBloomFilter to deduplicate RecordAction calls>
Pull request opened by <https://github.com/pingsutw|pingsutw>
*Summary*

closes <https://github.com/flyteorg/flyte/issues/6968|#6968>
• Add `OppoBloomFilter` to `ActionsClient` to deduplicate `RecordAction` gRPC calls caused by Kubernetes watch event replays on reconnect
• Add configurable `RecordFilterSize` (default 8M) to actions config
• Only add to filter after successful gRPC call so transient failures can be retried
• Graceful degradation: if filter creation fails, proceeds without dedup

*Test plan*

• `go build ./actions/...` passes
• `go test ./actions/...` passes
• Unit test: duplicate `watch.Added` events → `RecordAction` called only once
• Unit test: failed `RecordAction` allows retry on next event
• Unit test: nil filter (backward compat) calls `RecordAction` every time
• `main`  
   • <https://github.com/flyteorg/flyte/pull/6583|#6583>  
         • <https://github.com/flyteorg/flyte/pull/6987|#6987> :point_left:
<https://github.com/flyteorg/flyte|flyteorg/flyte>

<https://github.com/flyteorg/flyte/pull/6987|#6987 Add OppoBloomFilter to deduplicate RecordAction calls>
Pull request merged by <https://github.com/pingsutw|pingsutw>
<https://github.com/flyteorg/flyte|flyteorg/flyte>