From f672c04844d0277172e677830980cda36e07f41c Mon Sep 17 00:00:00 2001 From: Steve Nyemba Date: Mon, 7 Mar 2022 15:29:03 -0600 Subject: [PATCH] bugfix: sqlalchemy --- transport/sql.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/transport/sql.py b/transport/sql.py index e646a18..d408942 100644 --- a/transport/sql.py +++ b/transport/sql.py @@ -299,7 +299,7 @@ class SQLWriter(SQLRW,Writer): if self._engine : # pd.to_sql(_info,self._engine) - rows = _info.to_sql(table,self._engine,if_exists='append',index=False) + rows = _info.to_sql(table,self._engine,schema=self.schema,if_exists='append',index=False) else: _fields = ",".join(self.fields)