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,