add 1 second delay after query execution

Altinity · Apr 10, 2024 · c6c8d7e · c6c8d7e
1 parent 5ab54fe
commit c6c8d7e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/sink-connector-lightweight/tests/integration/helpers/cluster.py b/sink-connector-lightweight/tests/integration/helpers/cluster.py
@@ -804,6 +804,8 @@ def query(
                 ) if steps else NullStep():
                     try:
                         r = self.cluster.bash(None)(command, *args, **kwargs)
+                        time.sleep(1)
+                        note("I waited 1 second after the query execution")
                     except ExpectTimeoutError:
                         self.cluster.close_bash(None)
                         raise
@@ -823,6 +825,8 @@ def query(
             ) if steps else NullStep():
                 try:
                     r = self.cluster.bash(self.name)(command, *args, **kwargs)
+                    time.sleep(1)
+                    note("I waited 1 second after the query execution")
                 except ExpectTimeoutError:
                     self.cluster.close_bash(self.name)
                     raise