Bindi Pankhudi
Bindi Pankhudi
WIP tech spec: https://docs.google.com/document/d/1fNhe3Q--C7FPFwHBhTnxN_foy4zMqLlHC4dIAim9r2M/edit?usp=sharing
Since we already know the schema name, we could potentially check whether it exists rather than fetching all schemas and then comparing: ``` def _get_schemas_list( self, database_name: str | None...
To be explored: We might have to point to a connector python package or load a yaml file.
Since it's fairly low effort, makes sense to make the move.
Details here: https://docs.google.com/document/d/1iowiNsveJjo165QStiQWHEt9s4jTcdxiZeflq6DtplA/edit?usp=sharing
Suggested improvements post related refactoring which will enable the following changes. Related refactoring ticket: https://github.com/airbytehq/PyAirbyte/issues/225 1. Currently in `destination_snowflake_cortex/indexer.py` we convert chunks into airbyte messages and send them to PyAirbyte....
Related tickets: * https://github.com/airbytehq/airbyte/issues/38162 * https://github.com/airbytehq/airbyte/issues/38161 Changes in this PR: * Pass a new param `source_tag` when initializing `PineconeGRPC` module. Tag is set to "airbyte" by default. For integration tests,...