Source code for pypushflow.ActorInterface

from typing import Optional




class ActorInterface:
    """The interface that makes a class a pypushflow actor"""



    def trigger(self, inData: dict, _scope_id: Optional[str] = None, **_) -> None:
        """Call `_execute` with additional context."""
        raise NotImplementedError


    def _execute(self, inData: dict, _scope_id: Optional[str] = None, **_) -> None:
        """Execute and trigger downstream"""
        raise NotImplementedError

    @property
    def pool_resources(self) -> int:
        return 0