Method push_event

mlib/core/engine.py:54–64

Push event.

(self, event: Event)

        self.agents[agent.agent_id] = agent

    def push_event(self, event: Event) -> None:
        """Push event."""
        max_event_id = 1000000000
        if isinstance(event, MarketCloseEvent):
            event.event_id = max_event_id
        else:
            event.event_id = self._num_event
            self._num_event += 1
            assert event.event_id < max_event_id
        heapq.heappush(self.events, event)
        self._log(f"received new event, type: {event.__class__.__name__}, {event.time}")

    def push_events(self, events: list[Event]) -> None:
        """Push events."""