diff --git a/python_modules/libraries/dagster-dbt/dagster_dbt/core/dbt_event_iterator.py b/python_modules/libraries/dagster-dbt/dagster_dbt/core/dbt_event_iterator.py index 508e90c00b95e..5ffa200a422fc 100644 --- a/python_modules/libraries/dagster-dbt/dagster_dbt/core/dbt_event_iterator.py +++ b/python_modules/libraries/dagster-dbt/dagster_dbt/core/dbt_event_iterator.py @@ -1,4 +1,3 @@ -from collections import abc from concurrent.futures import ThreadPoolExecutor from typing import TYPE_CHECKING, Any, Callable, Dict, Generic, Iterator, Optional, Union, cast @@ -186,7 +185,7 @@ def _fetch_row_count_metadata( return None -class DbtEventIterator(Generic[T], abc.Iterator): +class DbtEventIterator(Generic[T], Iterator): """A wrapper around an iterator of dbt events which contains additional methods for post-processing the events, such as fetching row counts for materialized tables. """