diff --git a/airflow/providers/dbt/cloud/operators/dbt.py b/airflow/providers/dbt/cloud/operators/dbt.py index 8e9f310ce8e5b..18df34ce3ecd4 100644 --- a/airflow/providers/dbt/cloud/operators/dbt.py +++ b/airflow/providers/dbt/cloud/operators/dbt.py @@ -135,7 +135,7 @@ def execute(self, context: Context): account_id=self.account_id, payload={ "job_definition_id": self.job_id, - "status__in": DbtCloudJobRunStatus.NON_TERMINAL_STATUSES, + "status__in": str(list(DbtCloudJobRunStatus.NON_TERMINAL_STATUSES.value)), "order_by": "-created_at", }, ).json()["data"] diff --git a/tests/providers/dbt/cloud/operators/test_dbt.py b/tests/providers/dbt/cloud/operators/test_dbt.py index 2941c021baf44..3b0c1dab0956d 100644 --- a/tests/providers/dbt/cloud/operators/test_dbt.py +++ b/tests/providers/dbt/cloud/operators/test_dbt.py @@ -374,7 +374,7 @@ def test_execute_no_wait_for_termination_and_reuse_existing_run( account_id=account_id, payload={ "job_definition_id": self.config["job_id"], - "status__in": DbtCloudJobRunStatus.NON_TERMINAL_STATUSES, + "status__in": str(list(DbtCloudJobRunStatus.NON_TERMINAL_STATUSES.value)), "order_by": "-created_at", }, )