Skip to content

Commit

Permalink
Rename constant
Browse files Browse the repository at this point in the history
  • Loading branch information
alexkuzmik authored and andrescrz committed Sep 30, 2024
1 parent 294c81f commit ed29744
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -7,13 +7,13 @@
from . import create_span_message_batcher
from . import batch_manager

CREATE_SPANS_MESSAGE_BATCHER_FLUSH_INTERVAL = 1.0
CREATE_SPANS_MESSAGE_BATCHER_FLUSH_INTERVAL_SECONDS = 1.0
CREATE_SPANS_MESSAGE_BATCHER_MAX_BATCH_SIZE = 1000


def create_batch_manager(message_queue: queue.Queue) -> batch_manager.BatchManager:
create_span_message_batcher_ = create_span_message_batcher.CreateSpanMessageBatcher(
flush_interval_seconds=CREATE_SPANS_MESSAGE_BATCHER_FLUSH_INTERVAL,
flush_interval_seconds=CREATE_SPANS_MESSAGE_BATCHER_FLUSH_INTERVAL_SECONDS,
max_batch_size=CREATE_SPANS_MESSAGE_BATCHER_MAX_BATCH_SIZE,
flush_callback=message_queue.put,
)
Expand Down

0 comments on commit ed29744

Please sign in to comment.