From c3fd371cb70a6f19941bbcae6cd27c05effe1626 Mon Sep 17 00:00:00 2001
From: Steve Nyemba <nyemba@gmail.com>
Date: Fri, 2 Feb 2024 19:18:23 -0600
Subject: [PATCH] bug fixes: sqlite writer with sqlalchemy

---
 transport/disk.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/transport/disk.py b/transport/disk.py
index f5f8a97..fab5eb1 100644
--- a/transport/disk.py
+++ b/transport/disk.py
@@ -218,7 +218,7 @@ class SQLiteWriter(SQLite,DiskWriter) :
 				_data = [_data]
 			_table = self.table if 'table' not in _args else _args['table']
 			_df = pd.DataFrame(_data)
-			_df.to_sql(_table,self._engine.connect())
+			_df.to_sql(_table,self._engine.connect()if_exists='append',index=False)
 		except Exception as e:
 			print (e)
 		SQLiteWriter.LOCK.release()