-
Notifications
You must be signed in to change notification settings - Fork 4.1k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
don't update cursor for log messages and and default schema path coming from connector builder #19271
don't update cursor for log messages and and default schema path coming from connector builder #19271
Conversation
…ng from connector builder
airbyte-cdk/python/airbyte_cdk/sources/declarative/schema/json_file_schema_loader.py
Outdated
Show resolved
Hide resolved
|
||
# If we are not in a source_ module, the most likely scenario is we're processing a manifest from the connector builder | ||
# server which does not require a json schema to be defined. | ||
return "./{{options['name']}}.json" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
replaced the module check w/ a basic default. @sherifnada do you still need the changes r equested?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think over time we should probably just consolidate schemas into the YAML file. So this is a fine workaround.
|
||
# If we are not in a source_ module, the most likely scenario is we're processing a manifest from the connector builder | ||
# server which does not require a json schema to be defined. | ||
return "./{{options['name']}}.json" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think over time we should probably just consolidate schemas into the YAML file. So this is a fine workaround.
…ng from connector builder (#19271) * don't update cursor for log messages and and default schema path coming from connector builder * replace check for connector_builder module with a basic default file path * update changelog and patch version * catch the correct exception when pkgutil can't load json file
What
While connecting the wires for the connector builder server I found a few small issues when trying to make requests coming from the connector builder server that aren't present for real low code connectors.
How
The two fixes required are:
read()
from the connector builder, we don't have any modules prefixed bysource_
which makes sense because the builder server module is calledconnector_builder
. Simplest path forward is to allow that caveat in the default logic.read_records
we should only attempt to update the cursor on record messages and notAirbyteLogMessage
orAirbyteTraceMessage
which are now valid messages from the generator. They don't have any relevant fields to update state so we should just skip over these.