improving, documenting, or customizing an existing source (please link an issue or describe below)
Short description
Implements query_adapter_callback argument for sql database. Can be used to modify or completely replace the generated sqlalchemy query, e.g.:
def query_adapter_callback(query, table):
if table.name == "chat_channel":
# Only select active channels
return query.where(table.c.active.is_(True))
# Use the original query for other tables
return query
Note: this includes the commits of https://github.com/dlt-hub/verified-sources/pull/550 , will rebase after that is merged.Tell us what you do here
Short description
Implements
query_adapter_callback
argument for sql database. Can be used to modify or completely replace the generated sqlalchemy query, e.g.:Related Issues
Second part of https://github.com/dlt-hub/verified-sources/issues/531#issuecomment-2267646842
Additional Context