We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 84f1337 commit 4e094caCopy full SHA for 4e094ca
risingwave/core.py
@@ -554,7 +554,7 @@ def _run(
554
wait_interval_ms: int = DEFAULT_CURSOR_IDLE_INTERVAL_MS,
555
cursor_name: str = "default",
556
):
557
- cursor_name = f"{self.schema_name}.risingwave_py_cursor_{cursor_name}_{self.sub_name}"
+ cursor_name = f"risingwave_py_cursor_{cursor_name}_{self.schema_name}_{self.sub_name}"
558
fully_qual_sub_name = f"{self.schema_name}.{self.sub_name}"
559
560
if self.persist_progress:
0 commit comments