Changelog¶
in progress¶
Connector: Verified support for DuckDB 2.x
2026/10/21 v0.20.0¶
Keep datetime normalization compatible with dlt 1.31 while retaining support for older dlt releases.
Extract fragments of code into dedicated package dlt-filesystem.
Notifications: a job report through Apprise when a run ends.
--notify <apprise-url>and--notify-config <path-or-url>, both repeatable, send one short report per run, for its final outcome, to any target Apprise supports. Inline URLs receive every report, config entries route by their tags (success,failure,always), and--notify-on failurekeeps a job quiet while it works. Every target is checked before the load starts, and a report that cannot be sent afterwards only logs a warning. The report names schemes, stages and exception types, never URIs, query text or error messages. Installomniload[notify];run_ingesttakes the same options asnotify,notify_configandnotify_on. See Notifications.Turso, read and written.
turso:///path/to/app.dbis an in-process file andturso://host?authToken=...a remote database, Turso Cloud or a self-hostedtursodb --sync-server(tls=falsefor plain HTTP), each a source and a destination through pyturso’s own SQLAlchemy dialects (pip install 'omniload[turso]', not available on Windows). A remote database is read and written through a replica bootstrapped for the run and discarded after it; a destination run pushes the replica once the load has committed, and cannot be combined with--pipelines-dir. The destination writes to themainschema withappendandreplaceonly: a merge load into Turso deletes rows it should keep (tursodatabase/turso#6279), somerge,delete+insert,scd2and a source’s own merge resources are refused before anything is written, as is--full-refresh.
2026/09/27 v0.19.0¶
Filesystem:
dlt-filesystemdeclares what it imports. A standalonepip install dlt-filesystemlacked Polars, so reading a CSV failed withNo module named 'polars'. Polars is now a base dependency. BSON, the DuckDB CSV reader and the spreadsheet formats (XLSX, ODS) get thebson,duckdbandspreadsheetextras: without one, its formats are left out of the supported-formats message and their reader names the extra to install.omniloadinstalls are unchanged, since omniload already carries all of these.Filesystem: XLSX files, written. The local
file://destination writes.xlsxworkbooks with one worksheet named after the destination table, so a later load finds the table by that name. A value an Excel cell would store as a different value is refused, naming the column: an integer beyond 2^53, NaN or infinity, a string past 32,767 characters, a date before March 1900. Excel’s own precision is documented rather than refused: floats keep 16 significant digits and times read back to the millisecond. Nested values, binary and decimals are written as text, as CSV writes them.
2026/09/23 v0.18.0¶
The filesystem and blob stack builds as its own distribution,
dlt-filesystem. It moves topackages/dlt-filesystem/and declares its own dependencies, so a dlt user can install the readers, the strict lister and the Arrowreadintoshim without omniload’s dependency list: 136 distributions against 250. Nothing an existing install line resolves to changes.omniload,omniload[filesystem],omniload[iterable]andomniload[full]each resolve to the same set as before, because the extras now forward to the new distribution. The install hints a missing long-tail decoder prints namedlt-filesystem[iterable], which is the extra that supplies it.Tests: the memory-store fixtures keep to their own store. Two test modules subclass
MemoryFileSystemto hold their fixtures apart from fsspec’s process-global store, butstoreis a class attribute the subclass inherits rather than replaces, so theirclear()emptied the store the remote-filesystem tests write into at import time. Each subclass now carries its own.Tests: the Arrow
readintoshim’s write-handle test reads the instance. fsspec 2026.9.0 mirrorsreadintoontoArrowFilefor every mode, sohasattrno longer separates what fsspec provides from what the shim injects. The shim itself is unchanged and stays, because the supported floor isfsspec>=2024.6.Filesystem: Vortex files, read and write.
.vortex(and.vortex.gz) files read on every filesystem source, and the localfile://destination writes them. A remote or gzipped file is staged to a local temporary file first, because the Vortex library opens files by path only. Opt-in through the newvortexextra, which needs Python 3.11 or newer and is included infull.
2026/09/17 v0.17.0¶
SQL sources: an
adbcbridgebackend, ADBC over ODBC.--sql-backend adbcbridgereads a SQL source through the database’s ODBC driver via adbcBridge and yields Arrow record batches straight from the driver, with no Python row in between. SQLAlchemy still reflects the table and compiles the query, so--incremental-key,--sql-limit,--sql-exclude-columnsand theappendandmergestrategies work as with the other backends. The ODBC connection string is derived from the source URI for PostgreSQL, Microsoft SQL Server, CrateDB (over its PostgreSQL wire protocol) and MySQL;--sql-odbc-urigives it explicitly for anything else, andOMNILOAD_ODBC_DRIVER_<FAMILY>renames a driver. Column types arrive at the precision the column declares (a PostgreSQLTIMESTAMP(0)as seconds). Installed with theadbcbridgeextra (adbcBridge 0.1.3 or later, which keepstimestamptzinstants on a server whose session zone is not UTC), part offull. Thanks, @singhpratech.Filesystem: an HTTP block size of
0reads the body whole instead of handing back a file that cannot seek. fsspec’s streaming file reportsseekable()asTrueand then raises on the first seek, soblock_size=0broke every reader that seeks (Parquet, ORC, Feather, JSONL, and a headerless CSV given no column names to use) while CSV, JSON, BSON, MessagePack, CBOR and Avro went on working, so the failure read as format-specific rather than as a broken handle. It applies to the effective block size, soFSSPEC_HTTP_BLOCK_SIZE=0in the environment is covered as well as the keyword argument, which is what makes this reachable fromomniload ingestrather than only from a source built in Python.Filesystem: the Parquet writer no longer emits an integer column its own reader cannot open. Polars widens an integer past the signed 64-bit range to a 128-bit one, which Parquet has no type for: such a column was written as an untyped 16-byte
FIXED_LEN_BYTE_ARRAY, whichpyarrowrefuses to read at all and DuckDB returns as aBLOB, so the export left carrying a value no consumer could spend. A column whose values all fit0..2**64-1is now narrowed touint64and reads back unchanged, inside a struct or a list of structs as well as at the top level. The part of that band above2**63is where this writer is the alternativewrite_orcandwrite_featherare not, both of them refusing from there up. Past2**64-1, and on any negative in a column another row widened, all three refuse; this one names the offending value before the file is opened.Filesystem: a
dlt_sourceimplementation now declares the run options it consumes, instead of the run subtracting its own vocabulary from every call.filesystem_incrementalandcolumn_typesare named parameters on every reader in the family now, not names read out of**kwargs, so a caller passing something else in omniload’s own run vocabulary (page_size, say) gets it forwarded straight to the fsspec/Arrow constructor rather than silently dropped. Most backends ignore an unknown keyword; at least one (WebDAV) raises. A row-level--incremental-keyagainst one of these sources now raises for every scheme in the family (some silently accepted it before, since the guard was keyed on a value the caller had already cleared).
2026/09/10 v0.16.0¶
Filesystem:
filesystem()andreaders()accept every keyword dlt’s own accept. A call written againstdlt.sources.filesystemthat passeskwargs,client_kwargsorincrementalby keyword now works againstdlt_filesystem.source.adaptertoo, where it used to raiseTypeError.kwargsandclient_kwargsreach the fsspec constructor and its native client; anincrementalcursor carryingrow_orderorders the listing by its cursor field, matching dlt for bothlast_value_funcdirections. The three are appended keyword-only rather than placed where dlt has them, so no existing positional call changes meaning; the flip side is that compatibility is by keyword, since infilesystem()dlt’s positional slots forkwargsandclient_kwargsare whererequire_file_matchandfilesystem_incrementalsit.extract_content’s declared default is nowFalse, which is what it has always resolved to and what dlt declares; a caller who wants file content in the listing passesextract_content=True, as before. Declaringincrementalalso makes dlt attach itsIncrementalResourceWrapper, as it does to its own filesystem resource, so a caller readingresource.incrementalgets the wrapper: the cursor isresource.incremental.incremental, and a resource with no cursor applied is that beingNonerather thanresource.incrementalitself. Bound clones of one resource now share a cursor, which is what dlt’s do today rather than a guarantee; build separate resources where the cursors have to be independent.Filesystem: Apache Avro reads on every filesystem source.
file://events/day.avroloads, as doess3://bucket/events/day.data#avroand any other source that goes through the shared file readers. Avro is decoded withpolars, which is already a core dependency, so nothing new is installed. Logical types come back as themselves:dateas a date,timestamp-microsandtimestamp-millisas UTC-aware datetimes,time-microsas a time,decimalas a decimal.#columns=and#chunksize=work as they do on the other columnar readers. Avro is read-only: the Avro writer available here corrupts a list column that holds an empty list before a non-empty one, so registering it would offer an export that fails silently on ordinary data. Three Avro schemas have no mapping and are rejected by name rather than loaded in part: amapfield, a field typednulloutright, and a union of more than two branches.Filesystem:
file://writes CSV and Parquet through Polars. Both writers built their column union by hand, because dlt omits a null key rather than writing it, and Polars builds that union itself from every row of the load. What the move changes is how a value is spelled, not which rows are written. A boolean writes astrue/falsein CSV instead ofTrue/False, which is what the JSON and YAML writers already emit for the same value. A nested document writes as JSON ({"a": 1}) instead of as a Python repr ({'a': 1}), which no reader could parse, and binary as the base64 string the JSON writers use instead of asb'hi'. Under--loader-file-format parquet, the one load path that hands a writer native values, a time column carries nanosecond rather than microsecond precision, a datetime writes ISO 8601 with aTseparator, and a Parquet decimal column is declared with the format’s maximum precision rather than the source’s, which leaves the values and their scale as they were. Some floats are spelled differently in CSV without changing value:1e-05writes as0.00001,1e-07as1e-7, and a NaN asNaN. CRLF line endings and Snappy Parquet compression are unchanged, and so are the Parquet column types apart from the time and decimal changes named above: a reader that reports Arrow types showslarge_stringwhere it showedstring, which is the Arrow schema travelling alongside rather than the file’s own, while the decimal annotation itself moves to the format’s maximum precision and a wider fixed-length store. One case stops working: a Parquet export of a decimal column wider than 38 digits of precision, which PyArrow held in a 256-bit decimal and Polars cannot hold at all. The same column still exports to CSV, JSON, JSONL and YAML, digit for digit.Filesystem: Feather V2 reads on every filesystem source.
file://events/day.feather(or.arrow, or.ipc, or a#featherhint on any name) loads Apache Arrow IPC data through PyArrow, one record batch at a time, so a batched file is never materialized whole.#columns=and#chunksize=work as they do for ORC. Feather V1 is a different container and is refused by name rather than reported as a damaged file.Filesystem:
file://writes Feather V2.file://export/users.feather(or.arrow, or.ipc, or a#featherhint) writes one Arrow IPC file. Timezone-aware timestamps, times, decimals, nested lists and structs and all-null columns all reach the file as themselves when the writer is handed them. What a load delivers depends on dlt’s staging rather than on the writer, and the filesystem page carries that table: the default staging writes temporal, decimal and binary columns as text, Parquet staging writes nested values as JSON text, a wholly null column is dropped either way, and a duration column fails at extract. That isfile://-wide, not Feather’s.Filesystem: the supported-format message names formats, not extensions. A reader registered under several extensions listed all of them, so
.arrowand.ipcwould have read as separate formats alongside Feather. Only the canonical name is advertised now, matching what the write side already did for.yml.
2026/09/07 v0.15.0¶
Filesystem:
file://reads back every intermediate format dlt stages. The staged files were typed by runningfile(1)and matching its English output, which is absent on Windows, varies by version, and cannot tell gzipped CSV from gzipped JSONL because dlt compresses both. So--loader-file-format csvfailed with a JSON decode error, and an uncompressed JSONL intermediate loaded or was refused as an unknown format depending on how many rows it held, sincefilenames a one-line file differently from a many-line one. Both work now: the format comes from the name dlt gave the file, CSV is read with the delimiter, encoding and line terminator dlt wrote it with, and the staging directory names its own files rather than inheriting alayoutorextra_placeholdersmeant for a user’s real filesystem destinations. A format with no row-shaped reader, such asinsert_values, is named in the error instead of being misread as JSON, and a destination table in dlt’s reserved_dlt_namespace is refused rather than exported with dlt’s own bookkeeping mixed into the rows.Filesystem:
file://writes YAML.file://export/users.yaml(or.yml, or a#yamlhint) writes one document holding a sequence, one mapping per row, which is the shape the.yamlreader expands into a table. Keys keep the column order the load produced, non-ASCII text is written as itself rather than escaped, and a load with no rows writes an empty sequence. Writing YAML needs PyYAML, the sameomniload[iterable]extra that reading it needs.Filesystem:
file://writes JSON, and the writers are registered rather than hand-wired.file://export/users.json(or a#jsonhint) writes one JSON array document, which is the shape the.jsonreader expects. Registering a writer is now a single record indlt_filesystem.target.registry, the way readers already work: the supported-format tuple, the error message and the end-to-end test matrix are all derived from it, and a test fails when the documentation names a different set. Two writers claiming one format is now an error instead of last-one-wins.Filesystem: written files are UTF-8 whatever the process locale is. The readers decode as UTF-8 unconditionally, so a CSV or JSONL export containing non-ASCII text previously failed to write, or wrote bytes it could not read back, on a machine whose locale was not UTF-8.
Verified compatibility with Polars 2
CSV:
csv://now shares thefile://implementation. It stays a CSV-only scheme, and every existing command still resolves, but reading and writing are the local filesystem connector’s, so the behaviour changes. On read: values are typed rather than all-string (numbers and booleans are inferred; ISO date strings stay strings), a row whose fields are all empty is kept as a row of nulls instead of being dropped, an empty field loads as null when unquoted and as an empty string when quoted (the old reader dropped every empty field, so both produced null), and the path grammar gains globs, gzip, split form, Windows drive and UNC paths, and#csv_headless/#csv_duckdbhints. A rerun with no--incremental-strategynow appends rather than replacing; pass--incremental-strategy replacefor the previous behaviour, which a destination that implements no append disposition now requires rather than merely recommends (MongoDB is one, and rejects the load without it).merge,delete+insertandscd2are rejected, because the shared reader exposes no incremental or merge key, and--incremental-keyis rejected for the same reason: the row cursor it drove compared raw strings against parsed datetimes and crashed when given an interval, so it is removed rather than ported. File-level selection by modification time is available through--filesystem-incremental. A non-CSV selection (csv://data.jsonl,csv://feed.dat#parquet,csv://book.xlsx) is now rejected before any file is read; usefile://for those. On write, a load that dlt split across several files wrote only the first of them and still exited zero, silently dropping the rest; every row now reaches the output file, in a deterministic but not necessarily source order. A destination path naming a different known format (csv://out.jsonl,#parquet) is rejected, while an extensionless or unrecognized-extension path (csv://report,csv://out.dat) still writes CSV.Filesystem: added a reader for Apache ORC files.
Filesystem: added local ORC output through
file://, implemented with PyArrow and preserving columns first encountered in later rows.
2026/09/01 v0.14.0¶
Filesystem: Give the Arrow-backed filesystems (
file://,s3://,r2://,az://,hdfs://,rsync://) read handles that implementreadinto. fsspec’sArrowFilemirrors a fixed method list from the pyarrow stream it wraps and leavesreadintooff it, so any reader that fills a caller-supplied buffer fails. Gzip is where that surfaces: fsspec registers isal’sIGzipFileas itsgzipcodec whenisalimports and the stdlibGzipFileonly when it does not, and isal decompresses throughreadinto. A.gzfile read through any of those schemes therefore raisedAttributeError: 'ArrowFile' object has no attribute 'readinto'in an environment that merely carried the package, and read fine everywhere else. omniload declares no dependency on isal, but anything pullingxopeninto the same environment brings it on x86-64 and AArch64.Core: Add
--reshape <engine>:<spec>, restructuring each source document before it is loaded. It flattens nested objects into columns, coerces types, and leaves arrays as real lists rather than opaque JSON. Three engines:python:<module>:<callable>(per row, preservesDecimal),jq:<program>(per row, through Tikray) andpolars:<recipes>(per Arrow batch, compiled through macropipe). The jq and Polars engines need the newomniload[reshape]extra, and the Polars one needs an Arrow-yielding source, which today means MongoDB only. While a reshape is active the MongoDB source no longer json-hints top-level arrays, so they land as child tables rather than JSON columns. That last part is MongoDB-only: filesystem readers registermax_table_nesting = 0, so a list a reshape produces there stays a JSON column.MongoDB: Build a
PyMongoArrowContextper wire batch in the Arrow loaders rather than once per cursor.finish()leaves the builders it accumulated in place, so the shared context replayed each earlier batch as a row of nulls: a collection spanning two batches emitted phantom all-null rows, and did so on any primary key. Reachable sincedata_item_formatbecame settable per run.Connector: Added source and target adapters for the Delta Lake table format
2026/08/27 v0.13.0¶
mq-bridge: Require mq-bridge-py 0.4.7 (was 0.3.2) and add three transports: Redis Streams (
redis-streams+mqb://), Apache Pulsar (pulsar+mqb://) and WebSocket (websocket+mqb://). Pulsar is not built into mq-bridge but ships as a separate native plugin, installed via the newomniload[pulsar]extra and registered on demand; it stays out of the base install (and out ofomniload[full]) because its wheels require glibc >= 2.34 on x86_64, glibc >= 2.38 on aarch64, and omit Windows arm64, all narrower than omniload’s own platform floor. mq-bridge names its Redis endpointredis_streams, but a URI scheme cannot contain an underscore, so omniload addresses it asredis-streams+mqb://. Note that a WebSocket source is a server: mq-bridge binds the authority and ingests the frames clients push to it, so--source-tablenames the HTTP path served and the run is bounded bymax_messages/idle_timeout_msrather than by end-of-stream.mq-bridge: Nack the batches left outstanding at the end of a run instead of only closing the consumer, so the broker redelivers them immediately rather than after a visibility timeout. This covers both a failed load and a
--yield-limitthat truncated a batch mid-yield. On transports with no per-message nack – Kafka – this still only leaves the offset unadvanced, so redelivery waits for the next run or rebalance as before. Delivery is unchanged otherwise – still at-least-once, deduplicated on_mqb_id.Filesystem: build reader transformers from registration records instead of a second hand-written adapter list, and expose the DuckDB CSV reader through
#csv_duckdband.csv_duckdb.Connectors: Added support for Apache Pulsar, WebSockets, Redis streams. Thanks, @marcomq.
Connectors: Removed gRPC due to found issues. Thanks, @marcomq.
2026/08/24 v0.12.0¶
HTTP: Support
--filesystem-incrementalwhen every selected file returns a validLast-Modifiedheader. A glob over an HTML directory index obtains the timestamp with one metadata request per matched file. A concrete file reuses the header already returned during discovery. A missing or malformed header stops extraction and names the query-free file URL instead of receiving dlt’s synthesized current time and reloading on every run.HTTP: Resolve
*,?and recursive**wildcards against links exposed by a HTML directory index. The server’s index remains the boundary of what the source can discover.Table names: One quote-aware parser reads
catalog.schema.tablefor every source and destination, replacing six ad-hoc conventions that each did something different with the same spelling. Names are right-aligned, so a shorter name keeps its shape:tableandschema.tableare still spelled the way they were, with the MySQL and SQLite routing changes below the exception to what they mean. Components may be quoted individually with",`or[], which is how a name containing a dot is written; a whole path wrapped in one pair of backticks is refused by name, because each component quotes separately. Every platform declares the shape it accepts, so a name it cannot represent is rejected with a message that says what the platform takes and where to put the catalog instead, rather than being silently truncated or flattened. Thanks, @hampsterx.Table names: A three-component name now reaches the destination’s catalog. It sets
project_idon BigQuery,catalogon Databricks, the database on MotherDuck, andaws_data_catalogon Athena, which had no way to reach a non-default catalog at all. For Postgres, Snowflake, Redshift, MSSQL, Synapse and Trino the catalog is the database the connection opens, so the first component selects it:--dest-table reporting.public.ordersconnects toreportingwhatever the URI path said. That is a deliberate call, and the URI stays the way to pin one database for a run. DuckDB and CrateDB keep their two-level names, since neither can address a second database on one connection. Thanks, @hampsterx.Table names: Three behaviour changes come with that. A dotted MySQL or SQLite destination name is now routed rather than flattened:
--dest-table foo.baron MySQL writes tablebarin databasefoo, where it previously created one table whose name normalized from the literal stringfoo.bar, and SQLite’smain.widgetsno longer becomes a table calledmain.widgetsinmain. Both wrote to the wrong place before, so a pipeline relying on the old spelling loads somewhere new. And a three-part SQL source name is now refused rather than misparsed. It used to be cut at the first dot, sopublic.order.itemssilently became schemapublicand tableorder.items; SQL sources are two-level, so it now gets an error naming the accepted format and pointing at--source-urifor the catalog. A table whose own name contains a dot is spelledpublic."order.items". Thanks, @hampsterx.
2026/08/21 v0.11.0¶
Azure: Read
az://,adls://andabfss://throughpyarrow.fsinstead of adlfs, for the per-file open cost every glob load pays. Measured against Azurite: opening and reading 300 small blobs costs 2.4 ms/blob through Arrow against 6.7 ms/blob through adlfs, and a 64 MB read runs at 456 MB/s against 193 MB/s. Listing a glob is one recursive request, recursive only when the pattern crosses a level. One client serves flat-namespace and Gen2 accounts, which it detects itself, and a customaccount_hostnow yields both the Blob and the Data Lake endpoint so a Gen2 account behind a sovereign-cloud or emulator endpoint stays reachable. Every credential mode the connector accepts is carried over: account key, SAS token, service principal, and connection string, and a connection string’sDfsEndpointis honoured as given rather than derived. File-level incremental selection and its cursor identity are unchanged, so no cursor resets. Writing, and the staging download that serves a remote database file, continue to use adlfs. Thanks, @hampsterx.Azure: Two behaviour changes come with that move.
api_versionis no longer accepted on a source URI and is rejected with a named error, because Arrow pins the API version its bundled SDK speaks and offers no override; an emulator that enforces the version check needs to be started with--skipApiVersionCheck. And a source connection string now has to name its account: one that identifies the account by endpoint alone (a bareSharedAccessSignaturewith a customBlobEndpointand noAccountName) is rejected, because the reader takes the storage account as the root of the filesystem. Thanks, @hampsterx.
2026/08/18 v0.10.1¶
Azure: Scope file-level incremental cursors from connection-string sources to the parsed storage account and Blob endpoint. Different accounts using the same container and glob no longer share a cursor and silently skip files. Existing connection-string cursors reset once on upgrade, so the first run reads the selection again and
appendloads may duplicate rows. Use--full-refreshfor that first upgraded load when duplicates are unacceptable. Connection strings continue to reach adlfs unchanged.
2026/08/15 v0.10.0¶
HTTP: Serve
http://andhttps://through the filesystem family, so an HTTP URL reads with the same formats, format hints and reader hints as every other transport. New: gzipped documents, whole-JSON documents, XML, YAML, msgpack, CBOR, BSON and workbooks; a#formator#key=valuefragment on the URL; and, where the server serves byte ranges, reading in ranges instead of downloading the whole body first. A signed URL keeps working: the query string is treated as part of the address, so an escape that carries meaning (%2F) reaches the server preserved rather than decoded, and the query stays out of record identity, log lines, and the errors discovery and whole-body reads raise. A server that ignoresRangeand one that answers chunked with noContent-Lengthare read whole, as before. Thanks, @hampsterx.HTTP: Four behaviour changes come with that move. A re-run with no
--incremental-strategynow appends rather than replacing, matching the rest of the family, and an explicitappendorreplaceis now honoured;--incremental-keyis now rejected rather than ignored;--filesystem-incrementalis refused, because an HTTP response need not carry aLast-Modifiedheader and a missing one would read as “just now” and reload everything; and connection options can no longer ride the URI query string, since that is the address, so they are available only when building the source object directly, not throughomniload ingestorrun_ingest. Timeouts stay at 30 seconds and environment proxy and.netrcsettings are still honoured. Thanks, @hampsterx.Filesystem: Fixed
csv_headless, which named columns with a Polars argument that selects columns instead. Reading a header-less CSV either failed outright or returned one shifted row, whether the names came from--columnsor were generated. Thanks, @hampsterx.Filesystem: A
#formatfragment on a source URI is now honoured, not only one on--source-table. Reader hints (#key=value) were already read from either. Thanks, @hampsterx.Filesystem: Discovery no longer fails when a filesystem reports no size for a file, which any HTTP response without a
Content-Lengthdoes. Thanks, @hampsterx.Filesystem: Added a
jsonformat, so a.jsonfile loads on every transport in the family. An object becomes one row and an array one row per element, whether or not the document is pretty-printed, and a.jsonfile that holds line-delimited records still loads..jsonlkeeps its own strict one-record-per-line reader. A URI fragment of#jsonis now read as a format hint rather than as literal text. Thanks, @hampsterx.
2026/08/12 v0.9.2¶
Filesystem: Started honouring
--filesystem-incrementaland--columnson every transport in the family. They were accepted and then ignored on the fourteen schemes that build their resource through the shared locator, among themftp://,smb://,oss://,oci://,webhdfs://,dropbox://,gdrive://,sharepoint://anddbfs://. Thanks, @hampsterx.Filesystem: Stopped passing omniload’s own run parameters to fsspec filesystem constructors, which fragmented fsspec’s instance cache and would be rejected by a backend that validates its keyword arguments. A source URI query parameter sharing a name with one of those run options is now ignored rather than forwarded; the run parameter already took precedence over it, so no connection setting changes meaning. Thanks, @hampsterx.
2026/08/05 v0.9.1¶
Filesystem: List and read through every registered scheme, including
r2://,oss://,hdfs://,smb://,ftp://,dbfs://,oci://andwebhdfs://, by resolving a file’s modification date from the listing the filesystem client returns.
2026/08/04 v0.9.0¶
Database: Load SQLite and DuckDB databases that live on a remote filesystem, addressed by their plain object URI, for example
s3://analytics/snapshots/events.duckdb. Thanks, @hampsterx.Filesystem: Treat XLSX and ODS workbooks as multi-table sources by default, while preserving one-table loads through explicit worksheet selectors. Thanks, @hampsterx.
Filesystem: Refreshed S3 directory listings between repeated loads so file-level incremental runs detect newly uploaded objects.
Connectors: Added Azure Storage destination support for connection-string authentication and custom endpoints.
Connectors: Reject mixed Azure Storage credential modes instead of silently ignoring extra fields in source and destination URIs.
Filesystem: Fail ingestion when a concrete source path matches no file while keeping unmatched glob selections valid. Thanks, @hampsterx.
Filesystem: Added rsync source connector. Thanks, @oferchen.
Filesystem: Enabled loading multiple workbook worksheets as tables. Thanks, @hampsterx.
Filesystem: Enabled loading remote SQLite and DuckDB databases. Thanks, @hampsterx.
2026/07/27 v0.8.0¶
Core: Added real SCD2 loading when selecting the
scd2strategy. Thanks, @hampsterx.Filesystem: Added file-level incremental loading. Thanks, @hampsterx.
Filesystem: Migrated local filesystem access to Apache Arrow.
Filesystem: Added support for reading from Databricks, Dropbox, FTP, Google Drive, HDFS, OCI, OneDrive, OSS, R2, SharePoint, SMB, WebDAV, and WebHDFS.
Core: Applied a few bits of internal package refactoring.
2026/07/16 v0.7.0¶
Connectors: Added Azure Blob Storage (
az://) and Azure Data Lake Storage Gen2 (adls://,abfss://) source and destination adapters, backed byadlfs. Supports account-key, SAS-token, and service-principal auth. Thanks, @hampsterx.Connectors: Fixed remote filesystem destinations (Azure Blob, GCS, S3) aborting at the end of a load because the required
post_loadhook was missing from the shared base class. Thanks, @hampsterx.Filesystem: Added
#key=valuereader hint channel to source URIs to propagate options to source implementations. Thanks, @hampsterx.Filesystem: Added readers for CBOR, MessagePack, XML and YAML formats. Thanks, @hampsterx.
Filesystem: Added readers for Excel workbook (XLSX) and OpenDocument spreadsheet (ODS) formats.
Filesystem: Fixed and documented semantics of append/replace strategy and append/full-refresh behaviour. Thanks, @hampsterx.
Dependencies: Updated to dlt 1.29
2026/07/06 v0.6.0¶
Connectors: Added
file://source and destination adapters that read and write from/to local CSV / JSONL / Parquet files. Thanks, @hampsterx.Connectors: Refactored filesystem internals
Connectors: Migrated filesystem CSV reader from pandas to Polars
Filesystem readers: Added support for BSON. Thanks, @hampsterx.
2026/07/02 v0.5.0¶
Connectors: Updated to Asana client v5
Core: Started using standard Python logger, removed
--quietoptionAPI: Made option
--source-tableoptional to prepare for streaming sourcesConnectors: Added an mq-bridge source for streaming brokers (Kafka/NATS/AMQP/MQTT/ZeroMQ/IBM MQ/AWS SQS), via the
<transport>+mqb://URI scheme, with dotted query keys (e.g.tls.required=true) for nested config such as TLS. Thanks, @marcomq.Maintenance: Started using
orjsonacross the boardConnectors: Centralize file-format to reader mapping across all sources. Thanks, @hampsterx.
2026/06/25 v0.4.0¶
Maintenance: Refactored module namespace. If you are using omniload as a library, this introduces many breaking changes. However, the new layout is much more ergonomic.
Core: Added lazy-loading adapter module registry, to speed up startup times.
2026/06/24 v0.3.0¶
Feature: Added embeddable
run_ingest()Python API. Thanks, @hampsterx.Dependencies: Updated to dlt v1.28
Dependencies: Updated to clickhouse-connect v1
2026/06/21 v0.2.0¶
Kafka: Expanded
default_msg_processorinto a miniature decoding unitdlt: Migrated from
ensure_pendulum_datetimetoensure_pendulum_datetime_utc
2026/06/19 v0.1.0¶
Dependencies: Permitted installation of SQLAlchemy 2.0
Dependencies: Relaxed package requirements across the board
Documentation: Migrated from VitePress to Sphinx
Runtime: Used tqdm progress bar instead of spinner
2026/05/17 v0.0.0¶
Imported code from ingestr v0.14.155
Project: Make it a library: Streamlined dependencies, now relaxed and inlined
Project: Migrated from Hatch to vanilla setuptools
Project: Migrated from Makefile to Poe the Poet
Project: Started using
versioningitfor versioningProject: Standardized version handling
OCI: Modernized
DockerfileDocumentation: Trimmed README, copy editing
CI: Validated on Python 3.14
OCI: Updated to Python 3.14 and Debian 13 “trixie”
dlt: Turned off telemetry due to excessive requests
Runtime: Removed interactive mode
--yes, replaced with--dry-runPackaging: Modernized PyPI and OCI publishing