Kitaru

importer

Importer plugin contract and the import flow.

attributeFetcher
= Callable[[dict[str, Any]], Iterator[bytes] | AsyncIterator[bytes]]
attributeImportedItem
= ImportedSession | ImportFailure
attributeNODE_BATCH_SIZE
= 200
attributeParser
= Callable[[bytes, dict[str, Any]], Iterator[ImportedItem] | AsyncIterator[ImportedItem]]
attributeMAX_IMPORT_FAILURES
= 20