diff options
Diffstat (limited to 'python/task_server')
| -rw-r--r-- | python/task_server/globeop.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/python/task_server/globeop.py b/python/task_server/globeop.py index 613bf546..0b18886d 100644 --- a/python/task_server/globeop.py +++ b/python/task_server/globeop.py @@ -173,9 +173,9 @@ def insert_todb(engine, workdate: datetime.date): def upload_bond_marks(engine, workdate: datetime.datetime): d = workdate.date() df = pd.read_sql_query( - "SELECT identifier, price from list_marks(%s) " - "RIGHT JOIN list_positions(%s, NULL, False) " - "USING (identifier)", + "SELECT p.identifier, price from list_marks(%s) m " + "RIGHT JOIN list_positions(%s, NULL, False) p " + "ON m.identifier=p.figi; ", engine, params=(d, d), ) |