发布

  • [OPIK-99] Implement batching for spans creation (#298)

    frostbyte_neo 发布于 2024-09-30 14:16:24 +00:00

    • Batch processing draft

    • Batching draft

    • [DRAFT] Update backend emulator for tests, update message processing to use batching

    • Fix lint errors

    • Implement _process_create_span_batch_message method in MessageProcessor

    • Remove assert, add debug log message

    • Add base batcher unit test

    • Make batch manager flush all batches if streamer.flush() was called, add tests for span batcher

    • Add tests for batch manager

    • Add test for flushing thread

    • Add one more test for batch manager

    • Fix lint errors

    • Fix lint errors

    • Fix bug when backend emulator didn't add feedback scores to traces

    • Fix lint errors

    • Rename flush_interval to flush_interval_seconds

    • Enable debug logs for e2e tests. Update debug messages in message_processors.py

    • Remove export statement from e2e workflow

    • Enable backend build. Enable debug logs for e2e tests

    • Update docker compose and e2e workflow file

    • Make batching disabled by default in Opik client. It is now enabled manually in Opik clients created under the hood of SDK

    • Add more unit tests for message processing

    • Add docstring for _use_batching parameter

    • Add missing _SECONDS suffix

    • Rename constant

    • Undone e2e tests infra changes


    Co-authored-by: Andres Cruz andresc@comet.com

    下载附件