Function select

test/cluster/mzcompose.py:4120–4124

()

    """

    def select():
        with c.sql_cursor() as cursor:
            # This should hang instantly as the timestamp is far in the future,
            # until the cluster is dropped
            cursor.execute("SELECT * FROM counter_tbl AS OF 18446744073709551615")

    def subscribe():
        cursor = c.sql_cursor()