Skip to content

Commit

Permalink
init
Browse files Browse the repository at this point in the history
  • Loading branch information
bubriks committed Nov 28, 2024
1 parent 0d0757d commit 65fb8ce
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions python/hsfs/engine/python.py
Original file line number Diff line number Diff line change
Expand Up @@ -1493,6 +1493,7 @@ def _write_dataframe_kafka(
# make sure producer blocks and everything is delivered
if not feature_group._multi_part_insert:
producer.flush()
del producer
progress_bar.close()

# start materialization job if not an external feature group, otherwise return None
Expand Down

0 comments on commit 65fb8ce

Please sign in to comment.