| author | |
| committer | |
| log | 91cf202177b91719cbc7a67e6f5a685d309be691 |
| tree | 8873e06a810e92049529f0ca16cbf4e6a20bf953 |
| parent | d21a8d597b4f876d63b2e884817d2a28f4e94bf3 |
- Replace detached flush worker with scoped fiber in `AnalyticsService`
- Ensure periodic analytics flushing is tied to layer lifetime/cleanup1 files changed, 1 insertions(+), 1 deletions(-)
apps/server/src/telemetry/Layers/AnalyticsService.ts+1-1| ... | ... | @@ -134,7 +134,7 @@ const makeAnalyticsService = Effect.gen(function* () { |
| 134 | 134 | |
| 135 | 135 | yield* Effect.forever(Effect.sleep(1000).pipe(Effect.flatMap(() => flush)), { |
| 136 | 136 | disableYield: true, |
| 137 | }).pipe(Effect.forkDetach); | |
| 137 | }).pipe(Effect.forkScoped); | |
| 138 | 138 | |
| 139 | 139 | yield* Effect.addFinalizer(() => flush); |
| 140 | 140 |