Fix interface import
This commit is contained in:
parent
80bfd414ec
commit
3a8fd634c5
4 changed files with 13 additions and 8 deletions
|
@ -57,10 +57,10 @@ def get_consumers(conf: Optional[Dict[str, Any]] = None) -> List[BaseConsumer]:
|
|||
def _get_interface(name: str) -> Type[BaseInterface]:
|
||||
mod_name, cls_name = name.rsplit(".", 1)
|
||||
|
||||
mod = importlib.import_module(f".consumers.{mod_name}", package=__package__)
|
||||
mod = importlib.import_module(f".interfaces.{mod_name}", package=__package__)
|
||||
|
||||
res = getattr(mod, cls_name)
|
||||
assert issubclass(res, BaseConsumer)
|
||||
assert issubclass(res, BaseInterface)
|
||||
|
||||
return res
|
||||
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue