feat(cdk): connector builder support for file uploader#492
feat(cdk): connector builder support for file uploader#492Aldo Gonzalez (aldogonzalez8) wants to merge 19 commits into
Conversation
Co-authored-by: Maxime Carbonneau-Leclerc <3360483+maxi297@users.noreply.github.com> Co-authored-by: octavia-squidington-iii <contact@airbyte.com>
…otocol changes. (#457) Co-authored-by: Maxime Carbonneau-Leclerc <3360483+maxi297@users.noreply.github.com> Co-authored-by: octavia-squidington-iii <contact@airbyte.com> Co-authored-by: Aaron ("AJ") Steers <aj@airbyte.io> Co-authored-by: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
|
/autofix
|
|
/autofix
|
|
/autofix
|
|
/autofix
|
|
Closed in favor of #503 |
|
Closed in favor of #503 |
What
We want to implement support for the connector builder to communicate about the files that will be uploaded for the streams.
How
Current Implementation:
emit_connector_builder_messages=False):FileUploaderis instantiated with a standardFileWriter, which performs the actual file writing.emit_connector_builder_messages=True):FileUploaderis instantiated with aNoopFileWriter, preventing actual file writes.FileUploaderinstance is then wrapped byConnectorBuilderFileUploader.ConnectorBuilderFileUploader.upload()first calls the wrappedFileUploader.upload()(which populatesrecord.file_referencebut doesn't write the file) and then performs the Connector Builder-specific action of copyingfile_referenceattributes intorecord.data.