From c3ebd32a40b3df91ece89118b8c072d3f144b2a6 Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Fri, 2 Feb 2024 19:19: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 fab5eb1..e31a88f 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()if_exists='append',index=False) + _df.to_sql(_table,self._engine.connect(),if_exists='append',index=False) except Exception as e: print (e) SQLiteWriter.LOCK.release()