diff --git a/rowers/dataprepnodjango.py b/rowers/dataprepnodjango.py index 229f6289..57f13d2f 100644 --- a/rowers/dataprepnodjango.py +++ b/rowers/dataprepnodjango.py @@ -1236,7 +1236,12 @@ def dataprep(rowdatadf,id=0,bands=True,barchart=True,otwpower=True, engine = create_engine(database_url, echo=False) with engine.connect() as conn, conn.begin(): - data.to_sql('strokedata',engine,if_exists='append',index=False) + try: + data.to_sql('strokedata',engine,if_exists='append',index=False) + except OperationalError: + data.drop(columns=['rhythm'],inplace=True) + data.to_sql('strokedata',engine,if_exists='append',index=False) + conn.close() engine.dispose() return data