diff --git a/CHANGELOG.md b/CHANGELOG.md index cfceb79..11f652f 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -2,6 +2,12 @@ ## [Unreleased] +## [0.14.3] - 2023-09-18 + +### Fixed + +- Fix pandas DataFrame row numbers. + ## [0.14.2] - 2023-09-15 ### Added @@ -231,7 +237,9 @@ - First release -[Unreleased]: https://github.com/getindata/streaming-jupyter-integrations/compare/0.14.2...HEAD +[Unreleased]: https://github.com/getindata/streaming-jupyter-integrations/compare/0.14.3...HEAD + +[0.14.3]: https://github.com/getindata/streaming-jupyter-integrations/compare/0.14.2...0.14.3 [0.14.2]: https://github.com/getindata/streaming-jupyter-integrations/compare/0.14.1...0.14.2 diff --git a/setup.cfg b/setup.cfg index 39a4527..0a6e67b 100644 --- a/setup.cfg +++ b/setup.cfg @@ -1,5 +1,5 @@ [bumpversion] -current_version = 0.14.2 +current_version = 0.14.3 [tox:tox] envlist = py38 diff --git a/setup.py b/setup.py index 317b855..c47009f 100644 --- a/setup.py +++ b/setup.py @@ -8,7 +8,7 @@ from setuptools import find_packages, setup from setuptools.command.install import install -__version__ = "0.14.2" +__version__ = "0.14.3" HERE = Path(__file__).parent.resolve() diff --git a/streaming_jupyter_integrations/magics.py b/streaming_jupyter_integrations/magics.py index 8822da8..8addd78 100644 --- a/streaming_jupyter_integrations/magics.py +++ b/streaming_jupyter_integrations/magics.py @@ -558,7 +558,7 @@ def row_reader() -> None: if display_row_kind: res = [result.get_row_kind()] + res a_series = pd.Series(res, index=df.columns) - df = pd.concat([df, pd.DataFrame.from_records([a_series])]) + df = pd.concat([df, pd.DataFrame.from_records([a_series])], ignore_index=True) rows_counter.value += 1 if display_handle is None: display_handle = display.display(df, display_id=True) @@ -569,7 +569,7 @@ def row_reader() -> None: series = pd.Series( [pyflink_result_kind_to_string(result_kind)], index=df.columns ) - df = pd.concat([df, pd.DataFrame.from_records([series])]) + df = pd.concat([df, pd.DataFrame.from_records([series])], ignore_index=True) display.display(df) self.shell.user_ns["execution_result"] = df