diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index b222a6ed..b282a41a 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -125,9 +125,12 @@ def terminate_list( term_dict = {"T": [], "A": []} for term in p.lrange(key, 0, -1): termination = loads(term) - DealKind["termination"].from_dict(**termination).mtm_stage() + trade = DealKind["termination"].from_dict(**termination) + trade.mtm_stage() try: - build_termination(term_dict, conn, fund=fund, **termination) + term_dict["A" if termination["is_assignment"] else "T"].append( + trade.to_globeop() + ) except TypeError as e: logging.error(e) return |