From 2868ced2d35c2defc0c88a5223e31d1e6e2d357a Mon Sep 17 00:00:00 2001 From: elpresidank Date: Thu, 4 Jun 2026 09:06:28 -0500 Subject: [PATCH] Relax flow spec return types --- ts/packages/client/src/models/Triple.ts | 2 ++ ts/packages/flow/src/decoding/pdf-decoder.ts | 2 +- ts/packages/flow/src/extract/knowledge-extract.ts | 2 +- 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/ts/packages/client/src/models/Triple.ts b/ts/packages/client/src/models/Triple.ts index c9d7ca4c..dd7587fb 100644 --- a/ts/packages/client/src/models/Triple.ts +++ b/ts/packages/client/src/models/Triple.ts @@ -1,3 +1,5 @@ + + // Term type discriminators matching the wire format // i = IRI, b = BLANK node, l = LITERAL, t = TRIPLE (reified) export type TermType = "i" | "b" | "l" | "t"; diff --git a/ts/packages/flow/src/decoding/pdf-decoder.ts b/ts/packages/flow/src/decoding/pdf-decoder.ts index 97c57b44..492ab157 100644 --- a/ts/packages/flow/src/decoding/pdf-decoder.ts +++ b/ts/packages/flow/src/decoding/pdf-decoder.ts @@ -225,7 +225,7 @@ const onPdfDecodeMessage = Effect.fn("PdfDecoderService.onMessage")(function* ( yield* Effect.log(`[PdfDecoder] Finished processing document ${documentId}`); }); -export const makePdfDecoderSpecs = (): ReadonlyArray> => [ +export const makePdfDecoderSpecs = (): ReadonlyArray => [ makeConsumerSpec("decode-input", onPdfDecodeMessage), DecodeOutputProducer, DecodeTriplesProducer, diff --git a/ts/packages/flow/src/extract/knowledge-extract.ts b/ts/packages/flow/src/extract/knowledge-extract.ts index 3604bf47..38d60d34 100644 --- a/ts/packages/flow/src/extract/knowledge-extract.ts +++ b/ts/packages/flow/src/extract/knowledge-extract.ts @@ -278,7 +278,7 @@ const onKnowledgeExtractMessage = Effect.fn("KnowledgeExtractService.onMessage") } }); -export const makeKnowledgeExtractSpecs = (): ReadonlyArray> => [ +export const makeKnowledgeExtractSpecs = (): ReadonlyArray => [ makeConsumerSpec( "extract-input", onKnowledgeExtractMessage,