def publish()

in message_flow/events/publisher/domain_event_publisher.py [0:0]

• 7 lines of code
• 1 McCabe index (conditional complexity)

    def publish(
        self,
        aggregate_type: str,
        aggregate_id: str,
        domain_events: List[DomainEvent],
        *,
        headers: Dict[str, str] = {}