Repository navigation
AsyncRetriever cannot be used in DynamicSchemaLoader - parameter name mismatch #766
Description
Description
AsyncRetriever fails when used inside DynamicSchemaLoader for dynamic schema generation, throwing:
TypeError: ModelToComponentFactory.create_async_retriever() missing 1 required keyword-only argument: 'stream_slicer'
Root Cause
In airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py:
- Line 2556:
create_dynamic_schema_loaderpassespartition_router=...when creating the retriever - Line 837:
_create_component_from_modelpasses kwargs through unchanged - Line 3465:
create_async_retrieverexpectsstream_sliceras a required parameter
The parameter names don't match - partition_router is passed but stream_slicer is expected.
Steps to Reproduce
Use AsyncRetriever in a DynamicSchemaLoader in a declarative YAML connector:
schema_loader:
type: DynamicSchemaLoader
retriever:
type: AsyncRetriever
# ... AsyncRetriever config
Expected Behavior
AsyncRetriever should work in DynamicSchemaLoader just like SimpleRetriever does.
Suggested Fix
Either:
- Change line 2556 to pass stream_slicer=... instead of partition_router=...
- Or change line 3465 to accept partition_router instead of stream_slicer
Environment
- airbyte-cdk version: [latest ... cloud 7.0.4 ]
- Connector type: Declarative YAML (low-code)
---
**Internal Tracking:** https://github.com/airbytehq/oncall/issues/11848
Activity
ian-at-airbyte commentedon Oct 17, 2025
Blocking issue for this contribution: airbytehq/airbyte#66221
bakerbryce commentedon Mar 16, 2026
Ian Alton (@ian-at-airbyte) Any update or an ETA on when this bug might be reviewed and considered for a fix?
ian-at-airbyte commentedon Mar 16, 2026
This one isn't prioritized yet, Bryce. I'll raise it in the next planning session and see if it can be accommodated.
bakerbryce commentedon Mar 31, 2026
Ian Alton (@ian-at-airbyte) Checking in again. Any hint on a potential ETA by chance?
ian-at-airbyte commentedon Apr 1, 2026
Not this month. Sorry. The list of prioritized issues just became too long. Haven't forgotten about it though. Is it fair to say this is blocking a contribution contribution for you too?
devin-ai-integration commentedon Apr 1, 2026
Hi Allan Delmare (@allandelmare), thank you for reporting this issue and for the thorough root cause analysis!
I've confirmed the bug in the current codebase. The parameter name mismatch is clear:
create_dynamic_schema_loader(line 2573) passespartition_router=...when constructing the retrievercreate_simple_retriever(line 3278) acceptspartition_routeras a keyword argument — soSimpleRetrieverworks fine inDynamicSchemaLoadercreate_async_retriever(line 3722) expectsstream_sliceras a required keyword argument — causing theTypeErrorwhenpartition_routeris passed insteadThis has been escalated to the internal team for prioritization.
Need more help? Join Airbyte Community Slack for peer support, or if you're a Cloud customer, open a support ticket referencing this URL.
devin-ai-integration commentedon Apr 1, 2026
This issue is being tracked internally: https://github.com/airbytehq/oncall/issues/11848
ian-at-airbyte commentedon Apr 1, 2026
Actually scratch that. The AI likes this one and has high confidence in its fix. Let's see how it does.
fix: pass stream_slicer when creating retriever in DynamicSchemaLoader
bakerbryce commentedon Apr 1, 2026
Ian Alton (@ian-at-airbyte) Blocking adoption of Airbyte in totality for this particular client actually. This is the #1 most critical source system for any non-profits that use Blackbaud. Without it the other platforms don’t have very little to hook into.
Very glad to hear we have some progress!
Allan Delmare (@allandelmare) thanks again for all the work you put into this!