diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 738f7cb0..4fcecf9f 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -125,12 +125,13 @@ 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() try: build_termination(term_dict, conn, fund=fund, **termination) except TypeError as e: logging.error(e) return - + DealKind["termination"].mtm_upload() for k, v in term_dict.items(): if v and upload: dest = get_filepath(base_dir, (trade_type, k), fund) |