* V1 of source_orb connector
* add boostrap.md file
* add clause on Pagination to bootstrap.md
* add SUMMARY documentation
* add lookback_window_days connector parameter
* Add support for start_date parameter
* Add ability to transform record in order to un-nest IDs
* Add support for extracting event properties based on connector configuration
* pass through jdbc params
* fail if contains verifyServerCertificate
* do the same for all ssl params
* delete dead file
* slight refactor
* new method
* remove default value
* error message
* rename
* update as per comments
* Update exception message
* Bump version
* extract to method
* Update doc
* Revert "Update doc"
This reverts commit 097906fe64.
* Update doc
* delete dead code
* update doc
* Throw exception with better error message
* Add missing test
* Use MoreMaps::merge
* Add missing tests
* camel case
* Allow colliding parameters if values are equal
* Remove trailing &
* Throw IllegalArgumentException
* extract to constants
* Bump version in seed
* Update destination specs
* Facebook Marketing performance improvement
* add comments and little refactoring
* fix integration tests with the new config
* improve job status handling, limit concurrency to 10
* fix campaign jobs, refactor manager
* big refactoring of async jobs, support random order of slices
* update source _read_incremental to hook new state logic
* fix issues with timeout
* remove debugging and clean up, improve retry logic
* merge changes from #8234
* fix call super _read_increment
* generalize batch execution, add use_batch flag
* improve coverage, do some refactoring of spec
* update test, remove overrides of source
* add split by AdSet
* add smaller insights
* fix end_date < start_date case
* add account_id to PK
* add notes
* fix new streams
* fix reversed incremental stream
* update spec.json for SAT
* upgrade CDK and bump version
Co-authored-by: Dmytro Rezchykov <dmitry.rezchykov@zazmic.com>
Co-authored-by: Eugene Kulak <kulak.eugene@gmail.com>
* Fix exception in case password is not provided for Clickhouse source
Exception while checking connection:
java.lang.NullPointerException: Cannot invoke "com.fasterxml.jackson.databind.JsonNode.asText()" because the return value of "com.fasterxml.jackson.databind.JsonNode.get(String)" is null
* Update changelog
* Bump version for Source Clickhouse
* Bump version of source-clickhouse-strict-encrypt
* Update version in docs
* correct conflict in docs
* bump connector version
* correct doc
Co-authored-by: Marcos Marx <marcosmarxm@gmail.com>
* Use data source conn supplier for snowflake database
* Format code
* Reuse the same database in integration tests
* Close query stream
* Refactor snowflake staging sql operations
* Close result set
* Add annotations
* Bump version
* Bump version in seed
* added coupon stream
* correct small errors
* bump connector version
* format json file
* run format
Co-authored-by: aadityasinha-dotcom <aadityasinha009@gmail.com>
* Avoid redundant adapter construction
* Remove unused logger
* Avoid redundant creation of buffer map
* Decrease max batch byte size to 128 mb
* Format code
* Move data adapter to an instance variable
* Bump version
* Bump version in seed
* added human-readable errors in case of incorrect organization or repo names
* added change history
* added change history
* bumped github image version
* bumped github image version in source_specs.yaml file
* Use stream transfer manager in check command
* Refactor code
* Move the check method to s3 destination
* Bump versions
* Revert s3 version bump
* Bump gcs version in seed
* Add support to duplicate one stream multiple times
* Update cloud version
* Bump version
* Remove unused logger
* Add trace for each stream in mock source
* Fix cloud version
* Bump version in seed
* Check binlog position on mysql server before run sync job, add error description into log
* fix MySqlStrictEncryptSourceAcceptanceTest
* fix formatting
* fix review comments
* added java docs and fixed few minor comments
* fix formatting
* update versions
* update source_specs.yaml
* check if stream exists in source
* check if stream exists in source, added comment
* test skipping reading quotes stream
* format code
* airbyte-cdk version
* added __init__.py to unit_tests
* fix importing airbyte models
* bump the version
* update spec and def yamls
Co-authored-by: auganbay <auganenu@gmail.com>
* JDBC sources: update for sources that not have permissions issues
* Postgres, CockroachDB and DB2 sources: updated case when user has none permitted table
* Postgres, CockroachDB and DB2 sources: updated case when user has none permitted table
* Postgres, CockroachDB and DB2 sources: bump versions
* Postgres, CockroachDB and DB2 sources: bump source specs
* Postgres, CockroachDB and DB2 sources: revert changes for postgres-strict-encrypt
* Add AdAccount and Images stream implementation
* Update PR number
* Updated docker version
* Updated to linter
* Update to review
* Add comment to AdAccount read_records method
* Bumped version in seed, definitions and specs files
* dynamic date range
* raise exception if exites the cycle without error
* if range days is 1 already do not retry
* added unit tests
* added comments
* added comments
* common mock classes are moved to common module
* change read_records
* refactored get_date_params
* handle corner case
* added parse_dates function
* added test_streams
* check mock calls
* fix unit tests for chunk date range refactoring
* removed commented codes
* remove commented line
* refactor test_streams
* refactor CustomQuery.get_query
* remove TODO
* deleted unused json
* format
* fix chunk_date_range
* added docstring
* set range_days to 15 for ShoppingPerformanceReport
* refactor chunk_date_range
* format code 2
* call parent read_records method
* add return type in get_date_params
* change e to exception
* set start_date as end_date
* log page token has expired
* bump version
* updated spec and def yaml
Co-authored-by: auganbay <auganenu@gmail.com>
