diff options
| -rw-r--r-- | python/process_queue.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 8f864a34..5a76ce1a 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -264,7 +264,10 @@ def build_line(obj, queue_name='bond_trades'): obj['InitialMarginCurrency'] = obj['Currency'] if obj.get('AttachmentPoint') is None: obj['ExecutingBroker'] = obj['Counterparty'] - obj['Counterparty'] = 'BAMSNY' if obj['account_code'] == 'BAML' else 'SGFCM' + if obj['account_code'] == 'BAML': + obj['Counterparty'] = 'BAMSNY' + elif obj['account_code'] == 'WF': + obj['Counterparty'] = 'WELFEI' if obj['Clearing Facility'] is None: obj['Clearing Facility'] = 'NOT CLEARED' obj['Custodian'] = 'BOMLCM' |