Skip to content

Commit ed8024c

Browse files
committed
bug fix
1 parent cc07261 commit ed8024c

File tree

2 files changed

+8
-9
lines changed

2 files changed

+8
-9
lines changed

dataframe_test.py

Lines changed: 7 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -30,11 +30,10 @@ def tearDown(self) -> None:
3030
self.disconnect()
3131

3232
def test_table_creation(self):
33-
self._dataframe = self.e6x_connection.load_parquet('<file_path>')
34-
self._dataframe.select('col1','col2')
35-
36-
rows = self._dataframe.show()
37-
38-
for row in rows:
39-
print(row)
40-
33+
try:
34+
self._dataframe = self.e6x_connection.load_parquet('<filepath>')
35+
rows = self._dataframe.show()
36+
for row in rows:
37+
print(row)
38+
except BaseException as e:
39+
print(f"Exception :{e}")

e6data_python_connector/e6data_grpc.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1275,7 +1275,7 @@ def __exit__(self, exc_type, exc_val, exc_tb):
12751275
self.terminate()
12761276

12771277
def update_dataframe_map(self, dataframe : "DataFrame"):
1278-
self._dataframe_map.update({self._dataframe_count, dataframe})
1278+
self._dataframe_map.update({self._dataframe_count : dataframe})
12791279
self._dataframe_count = self._dataframe_count + 1
12801280

12811281
@property

0 commit comments

Comments
 (0)