diff options
Diffstat (limited to 'python/report_ops/sma.py')
| -rw-r--r-- | python/report_ops/sma.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/python/report_ops/sma.py b/python/report_ops/sma.py index bb58fe07..0d7fea61 100644 --- a/python/report_ops/sma.py +++ b/python/report_ops/sma.py @@ -159,13 +159,12 @@ class PositionReport(Deal, deal_type=None, table_name=None): cls._query = _sql_query[asset_class] @classmethod - def stage_positions(cls, cob, fund): + def gen_positions(cls, cob, fund): with cls._conn.cursor() as c: params = (cob, fund) if cls not in (TranchePosition,) else (cob,) c.execute(cls._query, params) for row in c: - position = cls.from_query(row._asdict(), cob, fund) - cls.staging_queue.append(position.serialize("position")) + yield cls.from_query(row._asdict(), cob, fund) @classmethod def build_buffer(cls, cob, fund, upload=False): |