diff --git a/libs/executors/garf/executors/__init__.py b/libs/executors/garf/executors/__init__.py index 14eafa1..f760a6d 100644 --- a/libs/executors/garf/executors/__init__.py +++ b/libs/executors/garf/executors/__init__.py @@ -57,4 +57,4 @@ def setup_executor( 'ApiExecutionContext', ] -__version__ = '1.0.2' +__version__ = '1.0.3' diff --git a/libs/executors/garf/executors/fetchers.py b/libs/executors/garf/executors/fetchers.py index 8c20951..808cded 100644 --- a/libs/executors/garf/executors/fetchers.py +++ b/libs/executors/garf/executors/fetchers.py @@ -57,7 +57,10 @@ def get_report_fetcher(source: str) -> type[report_fetcher.ApiReportFetcher]: if inspect.isclass(obj) and issubclass( obj, report_fetcher.ApiReportFetcher ): - return getattr(fetcher_module, name) + if not hasattr(obj, 'alias'): + return getattr(fetcher_module, name) + if obj.alias == fetcher.name: + return getattr(fetcher_module, name) except ModuleNotFoundError as e: raise report_fetcher.ApiReportFetcherError( f'Failed to load fetcher for source {source}, reason: {e}'