olinpin/us-disclosures
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(db): fix saving disclosures into db

Browse Source
This commit is contained in:
oliverhnat
2025-06-16 14:10:43 +00:00
parent 7e2b9d4158
commit 5e1349f869
1 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
disclosures/financial_disclosure.py
View File

@@ -96,7 +96,6 @@ class Disclosures:
documents[id] = self.getDocuments(name) documents[id] = self.getDocuments(name)
values = self.prepareValues(documents) values = self.prepareValues(documents)
tasks = [] tasks = []
sent = []
for v in values: for v in values:
message = f"New disclosure from {[name for id, name in members if id == v[0]][0]} for the year {v[1]}. {v[2]} {v[3]}" message = f"New disclosure from {[name for id, name in members if id == v[0]][0]} for the year {v[1]}. {v[2]} {v[3]}"
tasks.append(asyncio.create_task(self.send_message(message, v))) tasks.append(asyncio.create_task(self.send_message(message, v)))
@@ -105,10 +104,10 @@ class Disclosures:
results = await asyncio.gather(*tasks) results = await asyncio.gather(*tasks)
sent = [r for r in results if r] sent = [r for r in results if r]
self.insertDisclosures(sent) self.insertDisclosures(values)
self.log( self.log(
f"Sent {len(sent)} disclosures. Inserted {len(sent)} disclosures. Total disclosures {len(values)}" f"Sent {len(sent)} disclosures. Inserted {len(values)} disclosures. Total disclosures {len(values)}"
) )
def log(self, message): def log(self, message):