Add sleep method (#54)

risingwavelabs · Nov 29, 2024 · d40ec5e · d40ec5e
1 parent aded792
commit d40ec5e
Showing 1 changed file with 8 additions and 0 deletions.
diff --git 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)