Skip to content

A
alpha-mind
Commit 9f933615 authored by Dr.李's avatar Dr.李
Browse files
Options

fixed bug

parent 98b84f71
Show whitespace changes
Inline Side-by-side
Showing with 8 additions and 6 deletions
alphamind/data/engines/sqlengine.py
View file @ 9f933615
......@@ -788,6 +788,7 @@ class SqlEngine(object):
portfolios = df.portfolio.unique()
query = delete(Positions).where(
and_(
Positions.trade_date == ref_date,
Positions.type.in_(build_types),
Positions.universe.in_(universes),
......@@ -795,6 +796,7 @@ class SqlEngine(object):
Positions.source.in_(sources),
Positions.portfolio.in_(portfolios)
)
)
self.engine.execute(query)
df.to_sql(Positions.__table__.name,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment