diff --git a/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py b/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py index 43e91d6dd856a..08e4fea7f0283 100644 --- a/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py +++ b/python_modules/libraries/dagster-fivetran/dagster_fivetran/resources.py @@ -654,7 +654,7 @@ def fetch_fivetran_workspace_data( connector_details=connector_details, ) - if connector.has_bad_setup_state: + if not connector.is_connected: continue connectors_by_id[connector.id] = connector diff --git a/python_modules/libraries/dagster-fivetran/dagster_fivetran/translator.py b/python_modules/libraries/dagster-fivetran/dagster_fivetran/translator.py index 9a28107d7a7b2..b44d7390fafa9 100644 --- a/python_modules/libraries/dagster-fivetran/dagster_fivetran/translator.py +++ b/python_modules/libraries/dagster-fivetran/dagster_fivetran/translator.py @@ -49,8 +49,8 @@ def destination_id(self) -> str: return self.group_id @property - def has_bad_setup_state(self) -> bool: - return self.setup_state is not FivetranConnectorSetupStateType.CONNECTED + def is_connected(self) -> bool: + return self.setup_state is FivetranConnectorSetupStateType.CONNECTED @classmethod def from_connector_details(