Skip to content

Commit 4d5eed1

Browse files
Copilotsroussey
andcommitted
Fix Form 8-K metadata loading and add accession_number index
Co-authored-by: sroussey <127349+sroussey@users.noreply.github.com>
1 parent fa10b37 commit 4d5eed1

3 files changed

Lines changed: 13 additions & 13 deletions

File tree

src/config/DefaultDI.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -502,6 +502,7 @@ export const DefaultDI = () => {
502502
createStorage("form_8k_events", Form8KEventSchema, Form8KEventPrimaryKeyNames, [
503503
["cik", "filing_date"],
504504
["item_code"],
505+
["cik", "accession_number"],
505506
])
506507
);
507508
};

src/config/TestingDI.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -444,6 +444,7 @@ export function resetDependencyInjectionsForTesting() {
444444
new InMemoryTabularStorage(Form8KEventSchema, Form8KEventPrimaryKeyNames, [
445445
["cik", "filing_date"],
446446
["item_code"],
447+
["cik", "accession_number"],
447448
])
448449
);
449450
}

src/task/forms/ProcessAccessionDocFormTask.ts

Lines changed: 11 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -85,19 +85,17 @@ export class ProcessAccessionDocFormTask extends Task<
8585
let items: string | null | undefined;
8686
let report_date: string | null | undefined;
8787

88-
if (!cik || !form || !fileName) {
89-
const filingRepo = globalServiceRegistry.get(FILING_REPOSITORY_TOKEN);
90-
const filings = await filingRepo.query({ accession_number: accessionNumber });
91-
const filing = filings?.[0];
92-
if (!filing) throw new TaskError("Filing not found");
93-
cik = filing.cik;
94-
form = filing.form ?? undefined;
95-
filing_date = filing.filing_date;
96-
file_number = filing.file_number;
97-
items = filing.items;
98-
report_date = filing.report_date;
99-
fileName = fileName ?? filing.primary_doc;
100-
}
88+
const filingRepo = globalServiceRegistry.get(FILING_REPOSITORY_TOKEN);
89+
const filings = await filingRepo.query({ accession_number: accessionNumber });
90+
const filing = filings?.[0];
91+
if (!filing) throw new TaskError("Filing not found");
92+
if (!cik) cik = filing.cik;
93+
if (!form) form = filing.form ?? undefined;
94+
filing_date = filing.filing_date;
95+
file_number = filing.file_number;
96+
items = filing.items;
97+
report_date = filing.report_date;
98+
if (!fileName) fileName = filing.primary_doc;
10199

102100
if (!form) {
103101
throw new TaskError(`Filing ${accessionNumber} has no form type`);

0 commit comments

Comments
 (0)