Spaces:

Leon4gr45
/

brain

Running

brain / src /lib /tracing /subscribers.py

Upload folder using huggingface_hub (part 3)

a55ea57 verified 19 days ago

404 Bytes

from abc import ABC, abstractmethod
from typing import Iterable

from src.lib.tracing.events import TraceEvent


class TraceSubscriber(ABC):
    @abstractmethod
    def handle(self, event: TraceEvent) -> None:
        raise NotImplementedError("handle method not implemented")

    def handle_many(self, events: Iterable[TraceEvent]) -> None:
        for event in events:
            self.handle(event)

	from abc import ABC, abstractmethod
	from typing import Iterable

	from src.lib.tracing.events import TraceEvent


	class TraceSubscriber(ABC):
	@abstractmethod
	def handle(self, event: TraceEvent) -> None:
	raise NotImplementedError("handle method not implemented")

	def handle_many(self, events: Iterable[TraceEvent]) -> None:
	for event in events:
	self.handle(event)