diff options
Diffstat (limited to 'python/process_queue.py')
| -rw-r--r-- | python/process_queue.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index 5b85892a..2e8910d6 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -261,11 +261,11 @@ def build_line(obj, queue_name='bond_trades'): if obj['InitialMarginPercentage']: obj['InitialMarginCurrency'] = obj['Currency'] if obj.get('AttachmentPoint') is None: - obj['Counterparty'], obj['ExecutingBroker'] = 'SGFCM', obj['Counterparty'] + obj['ExecutingBroker'] = obj['Counterparty'] + obj['Counterparty'] = 'BOMLCM' if obj['account_code'] == 'BAML' else 'SGFCM' if obj['Clearing Facility'] is None: obj['Clearing Facility'] = 'NOT CLEARED' - if obj['AttachmentPoint'] is not None: - obj['Custodian'] = 'NONE' + obj['Custodian'] = 'NONE' elif queue_name == 'future_trades': obj['Deal Type'] = 'FutureDeal' |