diff --git a/dbt/adapters/risingwave/impl.py b/dbt/adapters/risingwave/impl.py index 61ca453..d42b724 100644 --- a/dbt/adapters/risingwave/impl.py +++ b/dbt/adapters/risingwave/impl.py @@ -1,3 +1,6 @@ +import time + +from dbt.adapters.base.meta import available from dbt.adapters.postgres.impl import PostgresAdapter from dbt.adapters.risingwave.connections import RisingWaveConnectionManager @@ -11,3 +14,8 @@ class RisingWaveAdapter(PostgresAdapter): def _link_cached_relations(self, manifest): # lack of `pg_depend`, `pg_rewrite` pass + + @available + @classmethod + def sleep(cls, seconds): + time.sleep(seconds)