Source code for faust.types.fixups
import abc
import typing
from typing import Iterable
if typing.TYPE_CHECKING:
from .app import AppT as _AppT
else:
class _AppT: ... # noqa
__all__ = ["FixupT"]
[docs]class FixupT(abc.ABC):
app: _AppT
@abc.abstractmethod
def __init__(self, app: _AppT) -> None: ...
[docs] @abc.abstractmethod
def enabled(self) -> bool: ...
[docs] @abc.abstractmethod
def autodiscover_modules(self) -> Iterable[str]: ...
[docs] @abc.abstractmethod
def on_worker_init(self) -> None: ...