Warning fixes:
1) Dependency warning related to snowflake-connector-python package.
2) Pydantic warning related to Pipe class - it had attribute schema, the same name was used in parent class BaseModel that had method with the same name (it is deprecated though, but still not deleted).
Debug logging enhancement:
1) Added logger.debug() messages in the mapping functions, which are useful to understand exactly where the collector crashed.
Error case:
2) Due to avoid logging duplication (current mapping logic have some nesting logic) - changed properties to the methods decorated with @ttl_cache.
Tests updates:
1) Updated tests with new adapter and client realisation + added a few pipes to the test.
2) Added Snowflake tests to our run-tests workflow.
Warning fixes: 1) Dependency warning related to
snowflake-connector-python package. 2) Pydantic warning related toPipeclass - it had attributeschema, the same name was used in parent classBaseModelthat had method with the same name (it is deprecated though, but still not deleted).Debug logging enhancement: 1) Added
Error case:
2) Due to avoid logging duplication (current mapping logic have some nesting logic) - changed properties to the methods decorated with
logger.debug()messages in the mapping functions, which are useful to understand exactly where the collector crashed.@ttl_cache.Tests updates: 1) Updated tests with new adapter and client realisation + added a few pipes to the test. 2) Added Snowflake tests to our run-tests workflow.