def send()

in shippers/logstash.py [0:0]

• 14 lines of code
• 6 McCabe index (conditional complexity)

    def send(self, event: dict[str, Any]) -> str:
        if "_id" not in event and self._event_id_generator is not None:
            event["_id"] = self._event_id_generator(event)

        event["tags"] = ["forwarded"]
        event["tags"] += self._tags

        event = normalise_event(event)

        # Let's move _id to @metadata._id for logstash
        if "_id" in event:
            event["@metadata"] = {"_id": event["_id"]}
            del event["_id"]

        self._events_batch.append(event)
        if len(self._events_batch) < self._max_batch_size:
            return _EVENT_BUFFERED

        self._send()

        return _EVENT_SENT