aboutsummaryrefslogtreecommitdiffstats
path: root/python/notify_novations.py
blob: aee6718bc662333408ab89a87ae5f517ddd19031 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import datetime
from mtm_status import get_latest_file


def contact_novation_counterparties(date):
    df = get_latest_file(date)
    df = df[
        (df["SwapType"].isin(["ASGM"]))
        & (df["ThirdPartyStatus.1"].isin(["Pending Consent"]))
    ]
    df = (
        df.groupby(["ExecutingBroker", "RemainingBroker"])["Novation Consent ID"]
        .apply(list)
        .reset_index()
    )
    for row in df.itertuples():
        print(row.ExecutingBroker, row.RemainingBroker, row[3])


if __name__ == "__main__":
    contact_novation_counterparties(datetime.date(2023, 3, 14))