Open-source data movement for ELT pipelines and AI agents — from APIs, databases & files to warehouses, lakes, and AI applications. Both self-hosted and Cloud.
This report presents the forensic synthetic code analysis of airbytehq/airbyte, a Python project with 21,622 GitHub stars. SynthScan v2.0 examined 3,573,533 lines of code across 14361 source files, recording 8437 pattern matches distributed across 27 syntactic categories. The overall adjusted score of 4.4 places this repository in the Likely human-written band.
The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).
This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.
Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.
This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.
The scanner identified 8437 distinct pattern matches across 27 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.
Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …nnectors/source-strava/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-appsflyer/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …tors/source-babelforce/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …e-rd-station-marketing/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …connectors/source-zoom/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …connectors/source-cart/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …nnectors/source-timely/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …source-tvmaze-schedule/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …tors/source-mailerlite/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …onnectors/source-wrike/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …/connectors/source-rss/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …rce-azure-blob-storage/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …s/source-commercetools/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-gutendex/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-iterable/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-news-api/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …rs/source-youtube-data/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ors/source-bigcommerce/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …nectors/source-shopify/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …/source-survey-sparrow/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …tors/source-greenhouse/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-teradata/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ource-tiktok-marketing/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …rs/source-zendesk-chat/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …onnectors/source-pendo/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …/source-aws-cloudtrail/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …connectors/source-okta/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-insightly/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-recruitee/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-persistiq/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ors/source-freshcaller/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-couchbase/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …/source-facebook-pages/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-lokalise/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …pier-supported-storage/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …connectors/source-jira/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ource-outbrain-amplify/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …source-coingecko-coins/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …s/source-google-sheets/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-dockerhub/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-us-census/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …tors/source-senseforce/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ors/source-azure-table/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …rce-scaffold-java-jdbc/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …connectors/source-tidb/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-qualaroo/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ce-yahoo-finance-price/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …onnectors/source-faker/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …connectors/source-tmdb/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ctors/source-waiteraid/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …tors/source-tplcentral/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-omnisend/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …tors/source-clickhouse/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …rs/source-freshservice/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …nectors/source-zenloop/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …nnectors/source-oracle/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …connectors/source-oura/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …ectors/source-commcare/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …nectors/source-klaviyo/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| HIGH | …/destination-sftp-json/integration_tests/acceptance.py | 0 | this fixture is a placeholder for external resources that acceptance test might require. | STRING |
| 1043 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …connectors/source-appsflyer/source_appsflyer/source.py | 80 | def is_aggregate_reports_reached_limit(self, response: requests.Response) -> bool: | CODE |
| LOW | …connectors/source-appsflyer/source_appsflyer/source.py | 87 | def is_raw_data_reports_reached_limit(self, response: requests.Response) -> bool: | CODE |
| LOW | …connectors/source-appsflyer/source_appsflyer/source.py | 394 | def is_start_date_before_earliest_date(self, start_date, earliest_date): | CODE |
| LOW | …connectors/source-appsflyer/unit_tests/test_streams.py | 113 | def test_backoff_time_retry_after_header(patch_base_class): | CODE |
| LOW | …connectors/source-appsflyer/unit_tests/test_streams.py | 146 | def test_transform_function_no_decimal(patch_base_class, original_value, field_schema, expected): | CODE |
| LOW | …ource-appsflyer/unit_tests/test_incremental_streams.py | 28 | def patch_incremental_base_class(mocker): | CODE |
| LOW | …ource-appsflyer/unit_tests/test_incremental_streams.py | 128 | def test_get_updated_state_exists_current_stream_and_empty_latest_record(patch_incremental_base_class, mocker): | CODE |
| LOW⚡ | …ource-appsflyer/unit_tests/test_incremental_streams.py | 158 | def test_supports_incremental(patch_incremental_base_class, mocker): | CODE |
| LOW⚡ | …ource-appsflyer/unit_tests/test_incremental_streams.py | 165 | def test_source_defined_cursor(patch_incremental_base_class, mocker): | CODE |
| LOW⚡ | …ource-appsflyer/unit_tests/test_incremental_streams.py | 171 | def test_stream_checkpoint_interval(patch_incremental_base_class, mocker): | CODE |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 165 | def transform_change_audit_stamps( | CODE |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 252 | def transform_targeting_criteria(record: Dict, dict_key: str = "targetingCriteria") -> Mapping[str, Any]: | CODE |
| LOW | …nectors/source-linkedin-ads/unit_tests/test_streams.py | 33 | def test_analytics_stream_slices(requests_mock): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 33 | def mock_analytics_cursor_params(): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 48 | def test_safe_http_client_create_prepared_request(components_module): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 67 | def test_safe_encode_http_requester_post_init(components_module): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 85 | def test_linkedin_ads_record_extractor_extract_records(components_module, mock_response): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 102 | def test_date_str_from_date_range(components_module): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 115 | def test_linkedin_ads_error_handler_invalid_url(components_module): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 134 | def test_linkedin_ads_error_handler_http_response(components_module): | CODE |
| LOW | …/connectors/source-linkedin-ads/unit_tests/conftest.py | 23 | def clear_cache_before_each_test(): | CODE |
| LOW⚡ | …nnectors/source-linkedin-ads/unit_tests/test_source.py | 69 | def _mock_initialize_cache_for_parent_streams(stream_configs: List[Dict[str, Any]]) -> List[Dict[str, Any]]: | CODE |
| LOW⚡ | …nnectors/source-linkedin-ads/unit_tests/test_source.py | 72 | def update_with_cache_parent_configs(parent_configs: list[dict[str, Any]]) -> None: | CODE |
| LOW | …nnectors/source-linkedin-ads/unit_tests/test_source.py | 99 | def test_should_retry_on_error(self, error_code, requests_mock, mocker): | CODE |
| LOW | …nnectors/source-linkedin-ads/unit_tests/test_source.py | 277 | def test_ad_campaign_analytics_stream(self, requests_mock): | CODE |
| LOW | …ests/mock_server/test_ad_member_job_title_analytics.py | 93 | def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_job_title_analytics.py | 120 | def test_transformations_applied(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_job_title_analytics.py | 152 | def test_incremental_sync_initial(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_job_title_analytics.py | 201 | def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_job_title_analytics.py | 228 | def test_analytics_data_fields(self, http_mocker: HttpMocker): | CODE |
| LOW | …inkedin-ads/unit_tests/mock_server/test_conversions.py | 44 | def _create_conversion_record( | CODE |
| LOW | …inkedin-ads/unit_tests/mock_server/test_conversions.py | 74 | def test_full_refresh_with_multiple_parent_accounts(self, http_mocker: HttpMocker): | CODE |
| LOW | …inkedin-ads/unit_tests/mock_server/test_conversions.py | 161 | def test_incremental_sync_initial(self, http_mocker: HttpMocker): | CODE |
| LOW | …inkedin-ads/unit_tests/mock_server/test_conversions.py | 190 | def test_incremental_sync_with_state(self, http_mocker: HttpMocker): | CODE |
| LOW | …inkedin-ads/unit_tests/mock_server/test_conversions.py | 256 | def test_parent_with_no_child_records(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_seniority_analytics.py | 93 | def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_seniority_analytics.py | 120 | def test_transformations_applied(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_seniority_analytics.py | 152 | def test_incremental_sync_initial(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_seniority_analytics.py | 201 | def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker): | CODE |
| LOW | …ests/mock_server/test_ad_member_seniority_analytics.py | 228 | def test_analytics_data_fields(self, http_mocker: HttpMocker): | CODE |
| LOW | …s/mock_server/test_ad_member_company_size_analytics.py | 96 | def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker): | CODE |
| LOW | …s/mock_server/test_ad_member_company_size_analytics.py | 123 | def test_transformations_applied(self, http_mocker: HttpMocker): | CODE |
| LOW | …s/mock_server/test_ad_member_company_size_analytics.py | 155 | def test_incremental_sync_initial(self, http_mocker: HttpMocker): | CODE |
| LOW | …s/mock_server/test_ad_member_company_size_analytics.py | 204 | def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker): | CODE |
| LOW | …s/mock_server/test_ad_member_company_size_analytics.py | 231 | def test_analytics_data_fields(self, http_mocker: HttpMocker): | CODE |
| LOW | …s/source-linkedin-ads/unit_tests/mock_server/config.py | 51 | def with_ad_analytics_reports(self, reports: List[Dict[str, Any]]) -> "ConfigBuilder": | CODE |
| LOW | …_tests/mock_server/test_ad_member_company_analytics.py | 93 | def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker): | CODE |
| LOW | …_tests/mock_server/test_ad_member_company_analytics.py | 120 | def test_transformations_applied(self, http_mocker: HttpMocker): | CODE |
| LOW | …_tests/mock_server/test_ad_member_company_analytics.py | 152 | def test_incremental_sync_initial(self, http_mocker: HttpMocker): | CODE |
| LOW | …_tests/mock_server/test_ad_member_company_analytics.py | 201 | def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker): | CODE |
| LOW | …_tests/mock_server/test_ad_member_company_analytics.py | 228 | def test_analytics_data_fields(self, http_mocker: HttpMocker): | CODE |
| LOW | …unit_tests/mock_server/test_custom_analytics_report.py | 91 | def _get_custom_analytics_report_config() -> list: | CODE |
| LOW | …unit_tests/mock_server/test_custom_analytics_report.py | 130 | def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker): | CODE |
| LOW | …unit_tests/mock_server/test_custom_analytics_report.py | 164 | def test_transformations_applied(self, http_mocker: HttpMocker): | CODE |
| LOW | …unit_tests/mock_server/test_custom_analytics_report.py | 210 | def test_incremental_sync_initial(self, http_mocker: HttpMocker): | CODE |
| LOW | …unit_tests/mock_server/test_custom_analytics_report.py | 271 | def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker): | CODE |
| LOW | …unit_tests/mock_server/test_custom_analytics_report.py | 304 | def test_analytics_data_fields(self, http_mocker: HttpMocker): | CODE |
| LOW | …unit_tests/mock_server/test_custom_analytics_report.py | 342 | def test_multiple_parent_campaigns(self, http_mocker: HttpMocker): | CODE |
| LOW | …-linkedin-ads/unit_tests/mock_server/test_creatives.py | 71 | def test_full_refresh_with_multiple_parent_accounts(self, http_mocker: HttpMocker): | CODE |
| LOW | …-linkedin-ads/unit_tests/mock_server/test_creatives.py | 161 | def test_incremental_sync_initial(self, http_mocker: HttpMocker): | CODE |
| 4014 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| CRITICAL | …ry/write/bulk_loader/ProtoToBigQueryCSVRowGenerator.kt | 567 | return com.google.cloud.bigquery.QueryParameterValue.timestamp(emittedAtMicroseconds) | CODE |
| CRITICAL | …lob-storage/source_azure_blob_storage/stream_reader.py | 10 | from azure.core.exceptions import ResourceNotFoundError | CODE |
| CRITICAL | …ns/destination/clickhouse/ClickhouseContainerHelper.kt | 38 | return container.containerInfo.networkSettings.networks.entries.first().value.ipAddress | CODE |
| CRITICAL | …tions/destination/gcs_data_lake/GcsPolarisWriteTest.kt | 36 | io.airbyte.cdk.load.data.icerberg.parquet.IcebergDataDumper( | CODE |
| CRITICAL | …_tests/sources/ClickHouseJdbcSourceAcceptanceTest.java | 139 | return Jsons.jsonNode(com.google.common.collect.ImmutableMap.of( | CODE |
| CRITICAL | …ors/source-instagram/integration_tests/test_streams.py | 58 | len(state_msg.state.stream.stream_state.__dict__.get("states", {})), | CODE |
| CRITICAL | …ns/connectors/source-gitlab/unit_tests/test_streams.py | 179 | assert commits._stream_partition_generator._partition_factory._retriever.requester.get_request_params() == {"with_st | CODE |
| CRITICAL | …grations/destination/oracle/OracleDestinationTest.java | 132 | return Jsons.jsonNode(com.google.common.collect.ImmutableMap.of( | CODE |
| CRITICAL | …egrations/destination/mssql/v2/MSSQLContainerHelper.kt | 46 | return testContainer.containerInfo.networkSettings.networks.entries.first().value.ipAddress | CODE |
| CRITICAL | …ination/singlestore/SingleStoreTypingDedupingTest.java | 75 | return io.airbyte.commons.json.Jsons.jsonNode(ImmutableMap.builder() | CODE |
| CRITICAL | …ination/singlestore/SingleStoreTypingDedupingTest.java | 137 | new io.airbyte.protocol.models.v0.ConfiguredAirbyteCatalog() | CODE |
| CRITICAL | …inglestore/SingleStoreSqlGeneratorIntegrationTest.java | 204 | .withJsonSchema(io.airbyte.protocol.models.Jsons.jsonNode(Map.of("type", "object", "properties", | CODE |
| CRITICAL | …inglestore/SingleStoreSqlGeneratorIntegrationTest.java | 218 | List.of(io.airbyte.protocol.models.Jsons.jsonNode(Map.of("_airbyte_raw_id", "ad3e8c84-e02e-4df4-b146-3d5a007b2 | CODE |
| CRITICAL | …egrations/source/mssql/MsSqlServerDebeziumConverter.kt | 280 | com.microsoft.sqlserver.jdbc.Geography.deserialize(bytes).toString() | CODE |
| CRITICAL | …egrations/source/mssql/MsSqlServerDebeziumConverter.kt | 283 | com.microsoft.sqlserver.jdbc.Geometry.deserialize(bytes).toString() | CODE |
| CRITICAL | …integrations/source/singlestore/SingleStoreSource.java | 97 | + com.singlestore.jdbc.export.SslMode.from(entry.getValue()).name(); | CODE |
| CRITICAL | …grations/source/singlestore/SingleStoreQueryUtils.java | 89 | new io.airbyte.protocol.models.v0.AirbyteStreamNameNamespacePair(name, namespace)); | STRING |
| CRITICAL | …grations/source/singlestore/SingleStoreQueryUtils.java | 111 | cursorBasedStatusMap.put(new io.airbyte.protocol.models.v0.AirbyteStreamNameNamespacePair(name, namespace), curs | STRING |
| CRITICAL | …ons/source/mongodb/cdc/MongoDbCdcStateHandlerTest.java | 27 | final MongoDbSourceConfig CONFIG = new MongoDbSourceConfig(io.airbyte.commons.json.Jsons.jsonNode( | CODE |
| CRITICAL | …b-v2/src/test/debezium/DebeziumMongoDbConnectorTest.kt | 114 | .using(io.debezium.engine.spi.OffsetCommitPolicy.AlwaysCommitOffsetPolicy()) | CODE |
| CRITICAL | …b-v2/src/test/debezium/DebeziumMongoDbConnectorTest.kt | 171 | .using(io.debezium.engine.spi.OffsetCommitPolicy.AlwaysCommitOffsetPolicy()) | CODE |
| CRITICAL | …ations/destination/snowflake/check/SnowflakeChecker.kt | 80 | io.airbyte.cdk.load.component.ColumnType("VARCHAR", false) | CODE |
| CRITICAL | …component/config/SnowflakeTestTableOperationsClient.kt | 56 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …connectors/source-pinterest/unit_tests/test_streams.py | 75 | result = stream._stream_partition_generator._partition_factory._retriever.requester.get_path( | CODE |
| CRITICAL⚡ | …ns/destination/postgres/write/PostgresRawDataDumper.kt | 397 | io.airbyte.cdk.load.data.IntegerValue( | CODE |
| CRITICAL⚡ | …ns/destination/postgres/write/PostgresRawDataDumper.kt | 401 | io.airbyte.cdk.load.data.NumberValue( | CODE |
| CRITICAL⚡ | …ns/destination/postgres/write/PostgresRawDataDumper.kt | 407 | io.airbyte.cdk.load.data.BooleanValue( | CODE |
| CRITICAL | …grations/connectors/source-hubspot/unit_tests/utils.py | 15 | stream_instance._stream_partition_generator._partition_factory._retriever.record_selector._transform(record, | CODE |
| CRITICAL | …ons/connectors/source-github/unit_tests/test_stream.py | 1559 | stream._parent_stream._http_client._session.cache.clear() | CODE |
| CRITICAL | …ons/connectors/source-github/unit_tests/test_stream.py | 1620 | stream._parent_stream._http_client._session.cache.clear() | CODE |
| CRITICAL | …tors/source-github/source_github/backoff_strategies.py | 42 | self.stream._http_client._session.auth.update_token() # New token will be used in next request | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt | 57 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt | 59 | io.airbyte.cdk.load.schema.model.TableNames( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt | 61 | io.airbyte.cdk.load.schema.model.TableName( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt | 67 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …taflow/state/stats/socket/EmittedStatsStoreImplTest.kt | 241 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| CRITICAL⚡ | …taflow/state/stats/socket/EmittedStatsStoreImplTest.kt | 243 | io.airbyte.cdk.load.schema.model.TableNames( | CODE |
| CRITICAL⚡ | …taflow/state/stats/socket/EmittedStatsStoreImplTest.kt | 245 | io.airbyte.cdk.load.schema.model.TableName( | CODE |
| CRITICAL⚡ | …taflow/state/stats/socket/EmittedStatsStoreImplTest.kt | 251 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 68 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 70 | io.airbyte.cdk.load.schema.model.TableNames( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 72 | io.airbyte.cdk.load.schema.model.TableName( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 78 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 500 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 502 | io.airbyte.cdk.load.schema.model.TableNames( | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 504 | io.airbyte.cdk.load.schema.model.TableName("namespace", "name") | CODE |
| CRITICAL⚡ | …/io/airbyte/cdk/load/message/DestinationMessageTest.kt | 507 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 52 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 54 | io.airbyte.cdk.load.schema.model.TableNames( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 56 | io.airbyte.cdk.load.schema.model.TableName( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 62 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 297 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 299 | io.airbyte.cdk.load.schema.model.TableNames( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 301 | io.airbyte.cdk.load.schema.model.TableName( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 307 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 393 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 395 | io.airbyte.cdk.load.schema.model.TableNames( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 397 | io.airbyte.cdk.load.schema.model.TableName( | CODE |
| CRITICAL⚡ | …o/airbyte/cdk/load/message/DestinationRecordRawTest.kt | 403 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …load/data/EnrichedDestinationRecordAirbyteValueTest.kt | 29 | io.airbyte.cdk.load.schema.model.StreamTableSchema( | CODE |
| 122 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …-lake/src/test-integration/resources/polaris/README.md | 20 | ### Step 1: Update Service Account Credentials File | COMMENT |
| LOW | …-lake/src/test-integration/resources/polaris/README.md | 29 | ### Step 2: Update PolarisEnvironment Configuration | COMMENT |
| LOW | …-lake/src/test-integration/resources/polaris/README.md | 50 | ### Step 3: Run the Tests | COMMENT |
| LOW | …/test-integration/resources/polaris/docker-compose.yml | 1 | # WARNING: This docker-compose.gcs.yml file is tightly coupled with PolarisEnvironment.kt. | COMMENT |
| LOW⚡ | …ectors/source-google-ads/unit_tests/test_components.py | 990 | # Step 1: Serialize MESSAGE fields | COMMENT |
| LOW⚡ | …ectors/source-google-ads/unit_tests/test_components.py | 998 | # Step 2: Flatten nested dicts | COMMENT |
| LOW⚡ | …ource-sendgrid/unit_tests/mock_server/test_contacts.py | 38 | # Step 1: Mock the export creation request (POST) | COMMENT |
| LOW | …ource-sendgrid/unit_tests/mock_server/test_contacts.py | 49 | # Step 2: Mock the polling request (GET status) - return "ready" status | COMMENT |
| LOW | …ource-sendgrid/unit_tests/mock_server/test_contacts.py | 67 | # Step 3: Mock the download request - return plain CSV with uppercase field names | COMMENT |
| LOW | …ortex/destination_snowflake_cortex/cortex_processor.py | 223 | # WARNING: This is untested and may not work as expected. | COMMENT |
| LOW⚡ | …urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java | 102 | // Step 1: Convert underscores to dashes (matches Debezium's normalizeName behavior) | COMMENT |
| LOW⚡ | …urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java | 105 | // Step 2: Replace special characters with underscores | COMMENT |
| LOW | …/test-integration/resources/polaris/docker-compose.yml | 1 | # WARNING: This docker-compose.yml file is tightly coupled with PolarisEnvironment.kt. | COMMENT |
| LOW | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 376 | // Step 1: Create principal and retrieve OAuth credentials (clientId and clientSecret) | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 401 | // Step 2: Create principal role (realm-wide) and catalog role (catalog-specific) | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 405 | // Step 3: Link catalog role to principal role for the specific catalog | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 418 | // Step 4: Grant required privileges to the catalog role | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 424 | // Step 5: Attach the principal role to the principal (completes the permission chain) | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 101 | // Step 1: Finalize the gzip CSV | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 116 | // Step 2: Upload to S3 | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 119 | // Step 3: Execute COPY | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 130 | // Step 4: Cleanup S3 staging file | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 142 | // Step 5: Reset state | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 219 | // Step 1: Resolve extended placeholders ({date:<format>}, {timestamp:millis|micro}) | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 241 | // Step 2: Resolve standard placeholders | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 252 | // Step 3: Ensure the file has the correct extension for Redshift COPY | COMMENT |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 229 | // Step 1: Materialize deduped rows into a session-scoped temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 232 | // Step 2: CDC hard-delete (if enabled) | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 251 | // Step 3: Update existing rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 254 | // Step 4: Insert new rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 257 | // Step 5: Drop temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 482 | // Step 1: Add temp column with the new type | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 484 | // Step 2: Cast data from old column to temp column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 486 | // Step 3: Record DESTINATION_TYPECAST_ERROR in _airbyte_meta for rows where | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 497 | // Step 4: Drop the original column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 499 | // Step 5: Rename temp column to the original name | STRING |
| LOW | …nectors/source-sftp-bulk/integration_tests/conftest.py | 52 | # Step 1: Extract the base CSV file from the ZIP archive | COMMENT |
| LOW | …nectors/source-sftp-bulk/integration_tests/conftest.py | 65 | # Step 2: Create duplicates with different names | COMMENT |
| LOW⚡ | docs/ai-agents/slack-app.md | 61 | ### Step 1: Sign in to Airbyte Agents | COMMENT |
| LOW⚡ | docs/ai-agents/slack-app.md | 67 | ### Step 2: Add the Slack connector | COMMENT |
| LOW⚡ | docs/ai-agents/slack-app.md | 73 | ### Step 3: Authenticate with Slack | COMMENT |
| LOW⚡ | docs/ai-agents/slack-app.md | 83 | ### Step 4: Save and verify | COMMENT |
| LOW⚡ | docs/ai-agents/slack-app.md | 89 | ### Step 5: Start using the connector | COMMENT |
| LOW | docs/ai-agents/admin/sso.md | 22 | ### Step 1: Create an SSO configuration | COMMENT |
| LOW | docs/ai-agents/admin/sso.md | 42 | ### Step 2: Verify your domain | COMMENT |
| LOW | docs/ai-agents/admin/sso.md | 63 | ### Step 3: Activate SSO | COMMENT |
| LOW | …agents/interfaces/api/authentication/build-your-own.md | 348 | // Step 1: Initiate OAuth when user clicks "Connect HubSpot" | COMMENT |
| LOW | …agents/interfaces/api/authentication/build-your-own.md | 378 | // Step 2: Handle OAuth callback - connector is already created | COMMENT |
| LOW | …agents/interfaces/api/authentication/build-your-own.md | 393 | // Step 3: Execute operations using the connector | COMMENT |
| LOW | docs/platform/using-airbyte/configuring-api-access.md | 28 | ## Step 1: Create an application | COMMENT |
| LOW | docs/platform/using-airbyte/configuring-api-access.md | 80 | ## Step 2: Get an access token | COMMENT |
| LOW | docs/platform/using-airbyte/configuring-api-access.md | 167 | ## Step 3: Use your access token | COMMENT |
| LOW | …r-development/connector-builder-ui/stream-templates.md | 67 | ### Step 1: Create a new connector in the Connector Builder | COMMENT |
| LOW | …r-development/connector-builder-ui/stream-templates.md | 79 | ### Step 2: Create a new Stream Template | COMMENT |
| LOW | …r-development/connector-builder-ui/stream-templates.md | 89 | ### Step 3: Configure Generated Stream Template | COMMENT |
| LOW | …r-development/connector-builder-ui/stream-templates.md | 109 | ### Step 4: Generate streams | COMMENT |
| LOW | …r-development/tutorials/building-a-java-destination.md | 49 | ### Step 1: Create the destination | COMMENT |
| LOW | …r-development/tutorials/building-a-java-destination.md | 53 | ### Step 2: Build the newly generated destination | COMMENT |
| LOW | …r-development/tutorials/building-a-java-destination.md | 178 | ### Step 3: Implement `spec` | COMMENT |
| LOW | …r-development/tutorials/building-a-java-destination.md | 204 | ### Step 4: Implement `check` | COMMENT |
| 473 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/bin/identify-dormant-workflows.py | 6 | CODE | |
| LOW | tools/schema_generator/tests/test_schema_generator.py | 11 | CODE | |
| LOW | tools/schema_generator/tests/test_schema_generator.py | 12 | CODE | |
| LOW | tools/schema_generator/tests/test_schema_generator.py | 12 | CODE | |
| LOW | tools/schema_generator/tests/test_schema_generator.py | 12 | CODE | |
| LOW | tools/schema_generator/tests/test_schema_generator.py | 12 | CODE | |
| LOW | tools/schema_generator/tests/test_schema_generator.py | 12 | CODE | |
| LOW | tools/schema_generator/tests/test_schema_generator.py | 12 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | tools/schema_generator/tests/tests.py | 5 | CODE | |
| LOW | …ols/schema_generator/schema_generator/infer_schemas.py | 29 | CODE | |
| LOW | …nnectors/source-appsflyer/source_appsflyer/__init__.py | 6 | CODE | |
| LOW | …connectors/source-appsflyer/source_appsflyer/source.py | 22 | CODE | |
| LOW | …s/source-appsflyer/source_appsflyer/fields/__init__.py | 1 | CODE | |
| LOW | …s/source-appsflyer/source_appsflyer/fields/__init__.py | 1 | CODE | |
| LOW | …ource-appsflyer/unit_tests/test_incremental_streams.py | 8 | CODE | |
| LOW | …rations/connectors/source-cart/source_cart/__init__.py | 25 | CODE | |
| LOW | …rations/connectors/source-cart/source_cart/__init__.py | 25 | CODE | |
| LOW | …rations/connectors/source-cart/source_cart/__init__.py | 25 | CODE | |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 24 | CODE | |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 24 | CODE | |
| LOW | …s/source-linkedin-ads/unit_tests/mock_server/config.py | 3 | CODE | |
| LOW | …s/source-linkedin-ads/unit_tests/mock_server/config.py | 4 | CODE | |
| LOW | …linkedin-ads/unit_tests/mock_server/request_builder.py | 3 | CODE | |
| LOW | …s/unit_tests/mock_server/test_ad_campaign_analytics.py | 11 | CODE | |
| LOW | …s/unit_tests/mock_server/test_ad_campaign_analytics.py | 12 | CODE | |
| LOW | …kedin-ads/unit_tests/mock_server/test_account_users.py | 3 | CODE | |
| LOW | …kedin-ads/unit_tests/mock_server/test_account_users.py | 12 | CODE | |
| LOW | …-linkedin-ads/unit_tests/mock_server/test_campaigns.py | 3 | CODE | |
| LOW | …-linkedin-ads/unit_tests/mock_server/test_campaigns.py | 12 | CODE | |
| LOW | …egrations/connectors/source-rss/source_rss/__init__.py | 6 | CODE | |
| LOW | …ctors/source-azure-blob-storage/build_customization.py | 4 | CODE | |
| LOW | …ure-blob-storage/source_azure_blob_storage/__init__.py | 6 | CODE | |
| LOW | …ure-blob-storage/source_azure_blob_storage/__init__.py | 7 | CODE | |
| LOW | …ure-blob-storage/source_azure_blob_storage/__init__.py | 8 | CODE | |
| LOW | …/source-commercetools/source_commercetools/__init__.py | 6 | CODE | |
| LOW | …ource-commercetools/source_commercetools/components.py | 6 | CODE | |
| LOW | …/destination-rabbitmq/destination_rabbitmq/__init__.py | 6 | CODE | |
| LOW | …nnectors/destination-kvdb/destination_kvdb/__init__.py | 24 | CODE | |
| LOW | …/connectors/source-iterable/source_iterable/streams.py | 18 | CODE | |
| LOW | …connectors/source-iterable/source_iterable/__init__.py | 1 | CODE | |
| LOW | …connectors/source-shopify/unit_tests/test_transform.py | 5 | CODE | |
| LOW | …rce-shopify/unit_tests/integration/test_bulk_stream.py | 7 | CODE | |
| LOW | …s/connectors/source-shopify/source_shopify/__init__.py | 25 | CODE | |
| LOW | …e-shopify/source_shopify/shopify_graphql/bulk/query.py | 14 | CODE | |
| LOW | …ctors/source-shopify/source_shopify/streams/streams.py | 6 | CODE | |
| LOW | …ctors/source-shopify/source_shopify/streams/streams.py | 42 | CODE | |
| LOW | …tors/destination-chroma/destination_chroma/__init__.py | 6 | CODE | |
| LOW | …tors/source-tiktok-marketing/unit_tests/test_source.py | 5 | CODE | |
| LOW | …ce-tiktok-marketing/unit_tests/integration/__init__.py | 3 | CODE | |
| LOW | …/source-zendesk-chat/unit_tests/pagination_strategy.py | 3 | CODE | |
| LOW | …zendesk-chat/unit_tests/mock_server/request_builder.py | 3 | CODE | |
| LOW | …e-zendesk-chat/unit_tests/mock_server/test_accounts.py | 12 | CODE | |
| LOW | …tination-amazon-sqs/destination_amazon_sqs/__init__.py | 6 | CODE | |
| 612 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | ruff.toml | 21 | # "ASYNC", # flake8-async | COMMENT |
| LOW | ruff.toml | 41 | # "INP", # flake8-no-pep420 | COMMENT |
| LOW | ruff.toml | 61 | # "SLOT", # flake8-slots | COMMENT |
| LOW | tools/bin/bulk-cdk/get-certified-connectors.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | tools/bin/bulk-cdk/get-certified-connectors.sh | 81 | # Nonobvious `printf | jq | jq` thing here: | COMMENT |
| LOW | tools/bin/cdk-auto-release/update-changelog.sh | 1 | #!/bin/bash | COMMENT |
| LOW | …ols/bin/bulk-cdk-compatibility-test/create-gh-issue.sh | 1 | #!/usr/bin/env bash | COMMENT |
| LOW | …ols/schema_generator/schema_generator/infer_schemas.py | 1 | # | COMMENT |
| LOW | …connectors/source-strava/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ons/connectors/source-appsflyer/unit_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ectors/source-babelforce/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …rce-rd-station-marketing/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …s/connectors/source-zoom/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …egrations/connectors/source-linkedin-ads/manifest.yaml | 1661 | # https://learn.microsoft.com/en-us/linkedin/shared/api-guide/concepts/rate-limits | COMMENT |
| LOW | …connectors/source-timely/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …/connectors/source-stock-ticker-api-tutorial/source.py | 1 | # MIT License | COMMENT |
| LOW | …s/source-tvmaze-schedule/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ectors/source-mailerlite/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …/connectors/source-wrike/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …tination/bigquery/formatter/BigQueryRecordFormatter.kt | 261 | value.nullify(Reason.DESTINATION_FIELD_SIZE_LIMITATION) | COMMENT |
| LOW | …integrations/destination/bigquery/BigQueryCheckTest.kt | 21 | CheckTestConfig( | COMMENT |
| LOW | airbyte-integrations/connectors/source-rss/__init__.py | 1 | # | COMMENT |
| LOW | …ns/connectors/source-rss/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ource-azure-blob-storage/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …tegrations/connectors/source-commercetools/__init__.py | 1 | # | COMMENT |
| LOW | …ors/source-commercetools/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …nnectors/destination-kvdb/destination_kvdb/__init__.py | 1 | # MIT License | COMMENT |
| LOW | …nnectors/source-gutendex/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …nnectors/source-news-api/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …tors/source-youtube-data/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ctors/source-bigcommerce/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …rs/source-survey-sparrow/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ectors/source-greenhouse/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …/clickhouse/component/ClickhouseTableOperationsTest.kt | 61 | // clickhouse doesn't have an explicit upsert table - we're relying on clickhouse's table engine | COMMENT |
| LOW | …ons/connectors/source-pendo/acceptance-test-config.yml | 21 | empty_streams: [] | COMMENT |
| LOW | …/connectors/source-pendo/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ation-amazon-sqs/destination_amazon_sqs/destination.py | 61 | # TODO: Support getting MessageDeduplicationId from a key in the record | COMMENT |
| LOW | …rs/source-aws-cloudtrail/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | airbyte-integrations/connectors/source-okta/__init__.py | 1 | # | COMMENT |
| LOW | …s/connectors/source-okta/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …nectors/source-insightly/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …connectors/source-recruitee/acceptance-test-config.yml | 21 | empty_streams: [] | COMMENT |
| LOW | …nectors/source-recruitee/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …rs/source-linkedin-pages/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …connectors/source-persistiq/acceptance-test-config.yml | 21 | empty_streams: [] | COMMENT |
| LOW | …nectors/source-persistiq/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …integrations/connectors/source-freshcaller/__init__.py | 1 | # | COMMENT |
| LOW | …ctors/source-freshcaller/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ons/connectors/source-couchbase/unit_tests/__init__.py | 1 | # | COMMENT |
| LOW | …nectors/source-couchbase/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ination/gcs_data_lake/write/GcsDataLakeStreamLoader.kt | 161 | // Instead, we write data using the new schema to the staging branch - that data will be | COMMENT |
| LOW | …nectors/source-appfollow/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …egrations/connectors/source-facebook-pages/__init__.py | 1 | # | COMMENT |
| LOW | …s/connectors/source-facebook-pages/tools/schema_gen.py | 181 | # }, | COMMENT |
| LOW | …s/connectors/source-facebook-pages/tools/schema_gen.py | 201 | # "id": { | COMMENT |
| LOW | …-integrations/connectors/source-lokalise/metadata.yaml | 21 | documentationUrl: https://docs.airbyte.com/integrations/sources/lokalise | COMMENT |
| LOW | …nnectors/source-lokalise/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ce-zapier-supported-storage/acceptance-test-config.yml | 21 | # exact_order: no | COMMENT |
| LOW | …zapier-supported-storage/integration_tests/__init__.py | 1 | # | COMMENT |
| LOW | …ors/source-outbrain-amplify/acceptance-test-config.yml | 1 | # See [Connector Acceptance Tests](https://docs.airbyte.com/connector-development/testing-connectors/connector-acceptanc | COMMENT |
| 534 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …ctors/source-azure-blob-storage/build_customization.py | 18 | base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y curl jq"], use_entrypoint=True | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 659 | return """{"__typename":"FulfillmentOrder","id":"gid:\/\/shopify\/FulfillmentOrder\/2","fulfillAt":"2023-04-24T18:00 | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 661 | {"__typename":"FulfillmentOrderMerchantRequest","id":"gid:\/\/shopify\/FulfillmentOrderMerchantRequest\/333","message":n | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 666 | return """{"__typename":"Order","updatedAt":"2023-09-09T09:57:43Z","order_id":"gid:\/\/shopify\/Order\/3944273805501 | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 667 | {"__typename":"Order","updatedAt":"2023-09-19T14:29:22Z","order_id":"gid:\/\/shopify\/Order\/3945528492221","risk":{"rec | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 672 | return """{"__typename":"Product","id":"gid:\/\/shopify\/Product\/123","publishedAt":"2021-06-23T01:09:29Z","created | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 687 | {"__typename":"MediaImage","createdAt":"2024-06-12T23:41:27Z","updatedAt":"2024-06-12T23:41:28Z","image":null,"__parentI | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 692 | return """{"__typename":"ProductVariant","id":"gid:\/\/shopify\/ProductVariant\/40091751448765","title":"Metal","pri | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 693 | {"__typename":"ProductVariantPricePair","price":{"amount":"64.0","currencyCode":"USD"},"compareAtPrice":null,"__parentId | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 694 | {"__typename":"ProductVariant","id":"gid:\/\/shopify\/ProductVariant\/41561955827901","title":"Test Variant 1","price":" | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 695 | {"__typename":"ProductVariantPricePair","price":{"amount":"19.0","currencyCode":"USD"},"compareAtPrice":null,"__parentId | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 700 | return """{"__typename":"InventoryItem","id":"gid:\/\/shopify\/InventoryItem\/44871665713341","harmonizedSystemCode" | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 701 | {"__typename":"InventoryItem","id":"gid:\/\/shopify\/InventoryItem\/45419395743933","harmonizedSystemCode":"330510","pro | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 707 | {"__typename":"Customer","id":"gid:\/\/shopify\/Customer\/456","defaultAddress":{"id":"gid:\/\/shopify\/MailingAddress\/ | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 712 | return """{"__typename":"Order","order_id":"gid:\/\/shopify\/Order\/4563761987773","createdAt":"2022-06-22T10:50:12Z | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 718 | {"__typename":"InventoryLevel","id":"gid:\/\/shopify\/InventoryLevel\/97912455357?inventory_item_id=42185200631997","can | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 719 | {"__typename":"InventoryLevel","id":"gid:\/\/shopify\/InventoryLevel\/97912455357?inventory_item_id=42185218719933","can | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 724 | return """{"__typename":"DiscountCodeNode","id":"gid:\/\/shopify\/DiscountCodeNode\/945205379261","codeDiscount":{"_ | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 725 | {"__typename":"DiscountRedeemCode","usageCount":0,"code":"HZAVNV2487WC","id":"gid:\/\/shopify\/DiscountRedeemCode\/11545 | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 726 | {"__typename":"DiscountRedeemCode","usageCount":0,"code":"SUMMERSALE10OFF","id":"gid:\/\/shopify\/DiscountRedeemCode\/13 | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 752 | return """{"__typename":"Order","id":"gid:\/\/shopify\/Order\/4554821468349","currency":"USD","transactions":[{"id": | CODE |
| HIGH | …tors/source-shopify/unit_tests/integration/api/bulk.py | 238 | {{"__typename":"Metafield","id":"gid:\/\/shopify\/Metafield\/{an_id}","namespace":"my_fields","value":"asdfasdf","key":" | CODE |
| HIGH | …tors/source-shopify/unit_tests/integration/api/bulk.py | 256 | return f"""{{"__typename":"Customer","id":"gid://shopify/Customer/{a_parent_id}","defaultAddress":{{"id":"gid:// | STRING |
| HIGH | …ector/destination_pgvector/common/sql/sql_processor.py | 26 | from sqlalchemy import Column, Table, and_, create_engine, insert, null, select, text, update | CODE |
| HIGH | …onnectors/destination-sftp-json/build_customization.py | 18 | base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y curl"], use_entrypoint=True) | CODE |
| HIGH | …-integrations/connectors/source-bing-ads/components.py | 339 | "Modified Time": null, | STRING |
| HIGH | …s/source-bing-ads/unit_tests/integrations/base_test.py | 75 | RequestBuilder(resource="User/Query", api="client_center").with_body('{"UserId": null}').build(), | CODE |
| HIGH | …ds/unit_tests/integrations/test_oauth_token_refresh.py | 22 | RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(), | CODE |
| HIGH | …ng-ads/unit_tests/integrations/test_accounts_stream.py | 39 | RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(), | CODE |
| HIGH | …ng-ads/unit_tests/integrations/test_accounts_stream.py | 67 | RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(), | CODE |
| HIGH | …ng-ads/unit_tests/integrations/test_accounts_stream.py | 103 | RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(), | CODE |
| HIGH | …ng-ads/unit_tests/integrations/test_accounts_stream.py | 151 | RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(), | CODE |
| HIGH | …/source-firebolt/integration_tests/integration_test.py | 45 | f"INSERT INTO {test_table_name} VALUES ('my_value',221,'2021-01-01','2021-01-01 12:00:01', Null, [1,2,3] | CODE |
| HIGH | …rations/connectors/source-fauna/source_fauna/source.py | 351 | q.lambda_("x", q.equals(q.select(["action"], q.var("x")), "remove")), | CODE |
| HIGH | …connectors/source-fauna/unit_tests/incremental_test.py | 284 | q.lambda_("x", q.equals(q.select(["action"], q.var("x")), "remove")), | CODE |
| HIGH | …connectors/source-fauna/unit_tests/incremental_test.py | 449 | q.lambda_("x", q.equals(q.select(["action"], q.var("x")), "remove")), | CODE |
| HIGH | …-salesforce/unit_tests/integration/test_bulk_stream.py | 288 | # default config does not set preserve_na_values -> historical behavior (NA-like strings -> null) | COMMENT |
| HIGH | …grations/connectors/source-file/build_customization.py | 18 | base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y curl"], use_entrypoint=True) | CODE |
| HIGH⚡ | …tions/connectors/source-file/unit_tests/test_client.py | 64 | assert read_file.equals(expected) | CODE |
| HIGH⚡ | …tions/connectors/source-file/unit_tests/test_client.py | 86 | assert read_file.equals(expected) | CODE |
| HIGH⚡ | …tions/connectors/source-file/unit_tests/test_client.py | 100 | assert read_file.equals(expected) | CODE |
| HIGH | …egrations/connectors/source-gcs/build_customization.py | 18 | base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y curl jq"], use_entrypoint=True | CODE |
| HIGH | …stination_snowflake_cortex/common/sql/sql_processor.py | 37 | null, | CODE |
| HIGH | …ons/connectors/source-marketo/source_marketo/source.py | 254 | Russell,Wilson,null,_mch-localhost-1536605780000-12105 | STRING |
| HIGH | …connectors/destination-pinecone/build_customization.py | 17 | return base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y build-essential gcc"], use_ | CODE |
| HIGH | …/connectors/source-netsuite/source_netsuite/streams.py | 103 | # Netsuite schemas do not specify if fields can be null, or not | COMMENT |
| HIGH | …e-integrations/connectors/source-hubspot/components.py | 907 | {"typeId": 3, "category": "HUBSPOT_DEFINED", "label": null} | STRING |
| HIGH | …e-integrations/connectors/source-hubspot/components.py | 916 | {"from_id": "123", "to_id": "456", "association_type_id": 3, "category": "HUBSPOT_DEFINED", "label": null} | STRING |
| HIGH | …s/connectors/source-hubspot/unit_tests/test_streams.py | 987 | f"listId should be a string to match the schema type [null, string], " | CODE |
| HIGH⚡ | …s/connectors/source-hubspot/unit_tests/test_streams.py | 956 | schema as [null, string]) can serialize the records without union-resolution failures. | STRING |
| HIGH⚡ | …s/connectors/source-hubspot/unit_tests/test_streams.py | 960 | then fails Avro union resolution against `[null, string]` at the destination. | STRING |
| HIGH | …/source-harvest/unit_tests/mock_server/test_company.py | 73 | # Mock empty response (company returns empty object or null) | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …connectors/source-appsflyer/source_appsflyer/source.py | 389 | except Exception as e: | CODE |
| MEDIUM | …connectors/source-appsflyer/source_appsflyer/source.py | 372 | def check_connection(self, logger, config) -> Tuple[bool, any]: | CODE |
| LOW | …byte-integrations/connectors/source-zoom/components.py | 86 | except Exception as e: | CODE |
| LOW | …egrations/connectors/source-cart/source_cart/source.py | 133 | except Exception as e: | CODE |
| LOW | …rations/connectors/source-rss/source_rss/components.py | 51 | except Exception: | CODE |
| LOW | …rations/connectors/source-rss/source_rss/components.py | 63 | except Exception: | CODE |
| MEDIUM | …rations/connectors/source-rss/source_rss/components.py | 48 | def is_newer(item, initial_state_date) -> bool: | CODE |
| LOW | …ce-azure-blob-storage/source_azure_blob_storage/run.py | 35 | except Exception: | CODE |
| LOW | …ource-commercetools/source_commercetools/components.py | 40 | except Exception as e: | CODE |
| LOW | …stination-rabbitmq/destination_rabbitmq/destination.py | 74 | except Exception as e: | CODE |
| LOW | …stination-rabbitmq/destination_rabbitmq/destination.py | 82 | except Exception as e: | CODE |
| LOW | …ctors/destination-kvdb/destination_kvdb/destination.py | 65 | except Exception as e: | CODE |
| LOW | …-shopify/source_shopify/shopify_graphql/bulk/record.py | 371 | except Exception as e: | CODE |
| LOW | …-shopify/source_shopify/shopify_graphql/bulk/record.py | 380 | except Exception as e: | CODE |
| LOW | …ctors/destination-chroma/destination_chroma/indexer.py | 44 | except Exception as e: | CODE |
| LOW | …ation-amazon-sqs/destination_amazon_sqs/destination.py | 173 | except Exception as e: | CODE |
| LOW | …tions/connectors/source-okta/unit_tests/test_source.py | 38 | except Exception as e: | CODE |
| LOW | …tions/connectors/source-okta/unit_tests/test_source.py | 51 | except Exception as e: | CODE |
| LOW | …tions/connectors/source-okta/unit_tests/test_source.py | 83 | except Exception as e: | CODE |
| MEDIUM | …tions/connectors/source-okta/unit_tests/test_source.py | 28 | def test_init_oauth2_authentication_wrong_credentials_record(self, wrong_oauth_c | CODE |
| MEDIUM | …tions/connectors/source-okta/unit_tests/test_source.py | 41 | def test_init_oauth2_authentication_wrong_oauth_config_bad_auth_type(self, wrong | CODE |
| LOW | …tions/connectors/source-okta/source_okta/components.py | 66 | except Exception as e: | CODE |
| LOW | …tions/connectors/source-okta/source_okta/components.py | 118 | except Exception as e: | CODE |
| MEDIUM | …tions/connectors/source-okta/source_okta/components.py | 55 | def refresh_access_token(self) -> Tuple[str, int]: | CODE |
| LOW | …onnectors/source-freshcaller/source_freshcaller/run.py | 28 | except Exception as error: | CODE |
| LOW | …connectors/source-couchbase/source_couchbase/source.py | 51 | except Exception as e: | CODE |
| LOW | …connectors/source-couchbase/source_couchbase/source.py | 62 | except Exception as e: | CODE |
| LOW | …ors/source-facebook-pages/source_facebook_pages/run.py | 26 | except Exception as error: | CODE |
| LOW | …rce-facebook-pages/source_facebook_pages/components.py | 51 | except Exception as e: | CODE |
| LOW | …rce-outbrain-amplify/source_outbrain_amplify/source.py | 1141 | except Exception as e: | CODE |
| LOW | …s/source-azure-table/source_azure_table/azure_table.py | 71 | except Exception as e: | CODE |
| LOW | …s/source-azure-table/source_azure_table/azure_table.py | 89 | except Exception as e: | CODE |
| LOW | …s/source-azure-table/source_azure_table/azure_table.py | 100 | except Exception as e: | CODE |
| LOW | …ectors/source-azure-table/source_azure_table/source.py | 56 | except Exception as e: | CODE |
| LOW | …ectors/source-azure-table/source_azure_table/source.py | 94 | except Exception as e: | CODE |
| LOW | …ectors/source-azure-table/source_azure_table/source.py | 128 | except Exception as e: | CODE |
| LOW | …stination-pgvector/destination_pgvector/destination.py | 72 | except Exception as e: | CODE |
| LOW | …ector/destination_pgvector/common/sql/sql_processor.py | 83 | except Exception as ex: | CODE |
| LOW | …ector/destination_pgvector/common/sql/sql_processor.py | 308 | except Exception as ex: | CODE |
| LOW | …nnectors/source-tplcentral/source_tplcentral/source.py | 68 | except Exception as e: | CODE |
| LOW | …nnectors/source-tplcentral/source_tplcentral/source.py | 85 | except Exception as e: | CODE |
| MEDIUM | …nnectors/source-tplcentral/source_tplcentral/source.py | 60 | def refresh_access_token(self) -> Tuple[str, int]: | CODE |
| LOW | …s/connectors/source-commcare/source_commcare/source.py | 54 | except Exception as ex: | CODE |
| LOW | …s/connectors/source-commcare/source_commcare/source.py | 119 | except Exception: | CODE |
| LOW | …e-integrations/connectors/source-klaviyo/components.py | 260 | except Exception as e: | CODE |
| LOW | …ination-sftp-json/destination_sftp_json/destination.py | 78 | except Exception as e: | CODE |
| LOW | …rce-google-directory/source_google_directory/client.py | 39 | except Exception as error: | CODE |
| LOW | …stination-firebolt/destination_firebolt/destination.py | 141 | except Exception as e: | CODE |
| LOW | …e-integrations/connectors/source-younium/components.py | 87 | except Exception as e: | CODE |
| LOW | …google-sheets/destination_google_sheets/destination.py | 38 | except Exception as err: | CODE |
| LOW | …tion-google-sheets/destination_google_sheets/client.py | 47 | except Exception as e: | CODE |
| LOW | …nectors/destination-astra/destination_astra/indexer.py | 84 | except Exception as e: | CODE |
| MEDIUM | …nectors/destination-astra/destination_astra/indexer.py | 73 | def check(self) -> Optional[str]: | CODE |
| LOW | …rs/destination-astra/destination_astra/astra_client.py | 43 | except Exception: | CODE |
| LOW | …/connectors/source-mixpanel/unit_tests/test_streams.py | 642 | except Exception as e: | CODE |
| LOW | …ions/connectors/source-mixpanel/source_mixpanel/run.py | 29 | except Exception as error: | CODE |
| LOW | …s/destination-sqlite/destination_sqlite/destination.py | 143 | except Exception as e: | STRING |
| LOW | …tors/destination-vectara/destination_vectara/client.py | 82 | except Exception as e: | CODE |
| LOW | …egrations/connectors/source-kyve/source_kyve/source.py | 32 | except Exception as e: | CODE |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 323 | except Exception as e: | CODE |
| 216 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nation/dynamodb/DynamodbDestinationAcceptanceTest.java | 56 | ((ObjectNode) failCheckJson).put("access_key_id", "fake-key"); | CODE |
| LOW | …onnectors/destination-rabbitmq/unit_tests/unit_test.py | 93 | data = {"name": "John Doe", "email": "john.doe@example.com"} | CODE |
| LOW | …onnectors/destination-rabbitmq/unit_tests/unit_test.py | 110 | data = {"name": "John Doe", "email": "john.doe@example.com"} | CODE |
| LOW | …s/connectors/source-iterable/unit_tests/test_source.py | 34 | responses.add(responses.GET, expected_url_base + "lists/getUsers?listId=1", body=b"user@example.com", status=200) | CODE |
| LOW | …ors/source-iterable/unit_tests/test_lookback_window.py | 205 | responses.get("https://api.iterable.com/api/lists/getUsers?listId=1", body="user@example.com") | CODE |
| LOW | …ors/source-iterable/unit_tests/test_lookback_window.py | 230 | responses.get("https://api.iterable.com/api/lists/getUsers?listId=1", body="user@example.com") | CODE |
| LOW | …ors/source-iterable/unit_tests/test_lookback_window.py | 257 | responses.get(expected_url_base + "lists/getUsers?listId=1", body="user@example.com") | CODE |
| LOW | …nnectors/source-iterable/unit_tests/test_extractors.py | 15 | b'{"itblInternal": 1, "_type": "event", "createdAt": "2024-03-21", "email": "user@example.com", "data": {"event_ | CODE |
| LOW | …nnectors/source-iterable/unit_tests/test_extractors.py | 31 | "email": "user@example.com", | CODE |
| LOW | …esk-chat/unit_tests/resource/http/response/agents.json | 6 | "display_name": "John Doe", | CODE |
| LOW | …grations/connectors/source-okta/unit_tests/conftest.py | 54 | "name": "fake_name", | CODE |
| LOW | …grations/connectors/source-okta/unit_tests/conftest.py | 90 | "name": "fake_name", | CODE |
| LOW | …s/source-jira/unit_tests/responses/issue_comments.json | 81 | "text": "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque eget venenatis elit. Duis | CODE |
| LOW | …s/source-jira/unit_tests/responses/issue_comments.json | 81 | "text": "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque eget venenatis elit. Duis | CODE |
| LOW | …tors/source-jira/integration_tests/invalid_config.json | 3 | "email": "test@test.com", | CODE |
| LOW | …s/connectors/source-azure-table/unit_tests/conftest.py | 16 | return {"storage_account_name": "dummy-value", "storage_access_key": "dummy-value", "storage_endpoint_suffix": "dumm | CODE |
| LOW | …laviyo/unit_tests/resource/http/response/profiles.json | 19 | "address1": "123 Main St", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 427 | "refresh_token": "dummy_token", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 428 | "lwa_app_id": "dummy_id", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 441 | "refresh_token": "dummy_token", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 442 | "lwa_app_id": "dummy_id", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 455 | "refresh_token": "dummy_token", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 456 | "lwa_app_id": "dummy_id", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 468 | "refresh_token": "dummy_token", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 469 | "lwa_app_id": "dummy_id", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 483 | "refresh_token": "dummy_token", | CODE |
| LOW | …source-amazon-seller-partner/unit_tests/test_source.py | 484 | "lwa_app_id": "dummy_id", | CODE |
| LOW | …ests/resource/http/response/shipping_zone_methods.json | 19 | "placeholder": "" | CODE |
| LOW | …ests/resource/http/response/shipping_zone_methods.json | 29 | "placeholder": "" | CODE |
| LOW⚡ | …commerce/unit_tests/resource/http/response/orders.json | 26 | "address_1": "123 Main St", | CODE |
| LOW⚡ | …commerce/unit_tests/resource/http/response/orders.json | 33 | "phone": "555-1234" | CODE |
| LOW⚡ | …commerce/unit_tests/resource/http/response/orders.json | 39 | "address_1": "123 Main St", | CODE |
| LOW⚡ | …merce/unit_tests/resource/http/response/customers.json | 17 | "address_1": "123 Main St", | CODE |
| LOW⚡ | …merce/unit_tests/resource/http/response/customers.json | 24 | "phone": "555-1234" | CODE |
| LOW⚡ | …merce/unit_tests/resource/http/response/customers.json | 30 | "address_1": "123 Main St", | CODE |
| LOW | …nit_tests/resource/http/response/payment_gateways.json | 20 | "placeholder": "" | CODE |
| LOW | …unit_tests/resource/http/response/product_reviews.json | 10 | "reviewer": "John Doe", | CODE |
| LOW | …e-typeform/integration_tests/invalid_config_oauth.json | 3 | "access_token": "fake-token", | CODE |
| LOW | …/source-typeform/integration_tests/invalid_config.json | 2 | "token": "fake-token", | CODE |
| LOW | …tors/destination-ragie/unit_tests/test_ragie_config.py | 15 | api_key="dummy_key", | CODE |
| LOW⚡ | …tors/destination-ragie/unit_tests/test_ragie_config.py | 39 | self.assertEqual(self.mock_config.api_key, "dummy_key") | CODE |
| LOW | …destination-ragie/unit_tests/test_ragie_destination.py | 28 | "api_key": "dummy-key", | CODE |
| LOW | …estination-starburst-galaxy/sample_secrets/config.json | 5 | "username": "user@example.com", | CODE |
| LOW | …nation-starburst-galaxy/src/test/resources/config.json | 5 | "username": "user@example.com", | CODE |
| LOW | …tination-starburst-galaxy/src/main/resources/spec.json | 42 | "examples": ["user@example.com"], | CODE |
| LOW | …galaxy/StarburstGalaxyS3DestinationAcceptanceTest.java | 38 | .put(S_3_ACCESS_KEY_ID, "fake-key") | CODE |
| LOW | …ns/connectors/source-salesforce/unit_tests/api_test.py | 369 | m.register_uri("POST", token_matcher, json={"instance_url": "https://fake-url.com", "access_token": "fake-token" | CODE |
| LOW | …ns/connectors/source-salesforce/unit_tests/api_test.py | 447 | m.register_uri("POST", token_matcher, json={"instance_url": "https://fake-url.com", "access_token": "fake-token" | CODE |
| LOW | …-hardcoded-records/source_hardcoded_records/streams.py | 39 | "email": "test@test.com", | CODE |
| LOW | …sts/resource/http/response/issuing_authorizations.json | 28 | "line1": "123 Main Street", | CODE |
| LOW | …e/unit_tests/resource/http/response/issuing_cards.json | 18 | "line1": "123 Main Street", | CODE |
| LOW | …e/unit_tests/resource/http/response/issuing_cards.json | 30 | "name": "John Doe", | CODE |
| LOW | …connectors/source-slack/sample_files/openapi_spec.json | 2928 | "name": "Acme Corp" | CODE |
| LOW | …connectors/source-slack/sample_files/openapi_spec.json | 2933 | "name": "Jane Doe" | CODE |
| LOW | …unit_tests/resource/http/response/payment_methods.json | 11 | "company_name": "Acme Corp", | CODE |
| LOW | …unit_tests/resource/http/response/payment_methods.json | 13 | "name": "Jane Doe", | CODE |
| LOW | …/postgres/legacy/AbstractPostgresSourceDatatypeTest.kt | 905 | .addInsertValues("'{lorem ipsum,dolor sit,amet}'") | CODE |
| LOW | …/postgres/legacy/AbstractPostgresSourceDatatypeTest.kt | 906 | .addExpectedValues("[\"lorem ipsum\",\"dolor sit\",\"amet\"]") | CODE |
| LOW⚡ | …nnectors/destination-cumulio/unit_tests/test_client.py | 85 | def test_batch_write_append_no_existing_dataset(cumulio_client: CumulioClient, dummy_data: Mapping[str, Any]): | CODE |
| LOW⚡ | …nnectors/destination-cumulio/unit_tests/test_client.py | 94 | write_buffer=dummy_data["data"], | CODE |
| 203 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | tools/bin/cdk-auto-release/update-changelog.sh | 182 | # Create a temporary file securely | COMMENT |
| MEDIUM | tools/bin/cdk-auto-release/update-changelog.sh | 363 | # Define the standard message here, could be made a script argument later | COMMENT |
| MEDIUM | …schema_generator/schema_generator/configure_catalog.py | 30 | # Create a dictionary representation of the configured catalog | COMMENT |
| MEDIUM | …/source-shopify/unit_tests/test_cached_stream_state.py | 11 | # Define the Stream instances for the tests | COMMENT |
| MEDIUM | …e-shopify/source_shopify/shopify_graphql/bulk/query.py | 2583 | # Create a dictionary to map the 'url' key in images | COMMENT |
| MEDIUM | …byte-integrations/connectors/source-jira/manifest.yaml | 14670 | # Defining a value here is difficult because the Jira API documentation mentions "REST API rate limits are not published | COMMENT |
| MEDIUM | …ce-google-sheets/unit_tests/integration/test_source.py | 977 | # Define a non-matching override | COMMENT |
| MEDIUM | …ce-google-sheets/unit_tests/integration/test_source.py | 1081 | # Define the schema fields and configured catalog with a primary key | COMMENT |
| MEDIUM | …ation_pgvector/common/destinations/record_processor.py | 187 | # Create a queue to store output messages | COMMENT |
| MEDIUM | …ector/destination_pgvector/common/sql/sql_processor.py | 905 | # Create a dictionary mapping columns in users_final to users_stage for updating | STRING |
| MEDIUM | …ector/destination_pgvector/common/sql/sql_processor.py | 924 | # Define a join between temp_table and final_table | STRING |
| MEDIUM | …ector/destination_pgvector/common/sql/sql_processor.py | 927 | # Define a condition that checks for records in temp_table that do not have a corresponding | STRING |
| MEDIUM | …s/connectors/source-commcare/source_commcare/source.py | 316 | # Create the streams from the collected names | COMMENT |
| MEDIUM | …ns/connectors/source-mixpanel/source_mixpanel/utils.py | 51 | # Define the list of fields that might contain date and time values. | COMMENT |
| MEDIUM | …ions/connectors/source-bing-ads/unit_tests/conftest.py | 185 | # Create a zip file containing the CSV file directly (without gzip compression) | COMMENT |
| MEDIUM | …/connectors/source-bing-ads/unit_tests/test_reports.py | 315 | # Create the full config with custom_reports | COMMENT |
| MEDIUM | …s/source-bing-ads/unit_tests/integrations/base_test.py | 40 | # Create a zip file containing the CSV file directly (without gzip compression) | COMMENT |
| MEDIUM | …s/destination-couchbase/unit_tests/test_destination.py | 51 | # Create a mock scope with no collections initially | COMMENT |
| MEDIUM | …ination-couchbase/destination_couchbase/destination.py | 62 | # Create a temporary collection for testing | COMMENT |
| MEDIUM | …destination-ragie/unit_tests/test_ragie_destination.py | 36 | # Create a test stream | COMMENT |
| MEDIUM | …tors/destination-ragie/unit_tests/test_ragie_writer.py | 36 | # Create a stream with proper AirbyteStream object | COMMENT |
| MEDIUM | …connectors/source-google-ads/unit_tests/test_source.py | 214 | # Create a fake customer_client_stream | COMMENT |
| MEDIUM | …ectors/source-google-ads/unit_tests/test_google_ads.py | 270 | # Define the fields we want metadata for | COMMENT |
| MEDIUM | …ation-motherduck/destination_motherduck/destination.py | 396 | # Create a dummy catalog to check if the SQL processor works | COMMENT |
| MEDIUM | …tors/source-salesforce/source_salesforce/exceptions.py | 12 | # Define the instance of the Native Airbyte Logger | COMMENT |
| MEDIUM | …nnectors/destination-cumulio/unit_tests/test_client.py | 23 | # Create a mock configuration dictionary | COMMENT |
| MEDIUM | …tegrations/connectors/source-s3/source_s3/v4/source.py | 206 | # The following function will wrap the execution in proper error handling. | COMMENT |
| MEDIUM | …owflake_cortex/common/destinations/record_processor.py | 190 | # Create a queue to store output messages | COMMENT |
| MEDIUM | …stination_snowflake_cortex/common/sql/sql_processor.py | 923 | # Create a dictionary mapping columns in users_final to users_stage for updating | STRING |
| MEDIUM | …stination_snowflake_cortex/common/sql/sql_processor.py | 942 | # Define a join between temp_table and final_table | STRING |
| MEDIUM | …stination_snowflake_cortex/common/sql/sql_processor.py | 945 | # Define a condition that checks for records in temp_table that do not have a corresponding | STRING |
| MEDIUM | …on-http-tutorial/source_python_http_tutorial/source.py | 64 | # This method is called once for each record returned from the API to compare the cursor field value in that rec | COMMENT |
| MEDIUM | …s/source-zendesk-support/unit_tests/test_components.py | 57 | # Create an instance of the extractor | COMMENT |
| MEDIUM | …s/source-zendesk-support/unit_tests/test_components.py | 90 | # Create an instance of the extractor | COMMENT |
| MEDIUM | …-zendesk-support/unit_tests/mock_server/test_topics.py | 66 | # Create the next page request first - this URL will be used in links.next | COMMENT |
| MEDIUM⚡ | …sk-support/unit_tests/mock_server/test_custom_roles.py | 52 | # Create a record with updated_at timestamp after start_date so it passes the date filter | COMMENT |
| MEDIUM | …-zendesk-support/unit_tests/mock_server/test_brands.py | 91 | # Create the next page request first - this URL will be used in links.next | COMMENT |
| MEDIUM | …ce-zendesk-support/unit_tests/mock_server/test_tags.py | 51 | # Create the next page request first - this URL will be used in links.next | COMMENT |
| MEDIUM | …endesk-support/unit_tests/mock_server/test_sections.py | 54 | # Create the next page request first - this URL will be used in links.next | COMMENT |
| MEDIUM | …desk-support/unit_tests/mock_server/test_categories.py | 54 | # Create the next page request first - this URL will be used in links.next | COMMENT |
| MEDIUM | …esk-support/unit_tests/mock_server/test_automations.py | 51 | # Create the next page request first - this URL will be used in links.next | COMMENT |
| MEDIUM | …e-zendesk-support/unit_tests/mock_server/test_posts.py | 60 | # Create the next page request first - this URL will be used in links.next | COMMENT |
| MEDIUM⚡ | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 332 | # Create a mock response for requests.head | COMMENT |
| MEDIUM | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 291 | # Create a mock response for requests.head | COMMENT |
| MEDIUM | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 297 | # Create a mock response for requests.get | COMMENT |
| MEDIUM | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 355 | # Create a mock response for requests.head | COMMENT |
| MEDIUM | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 399 | # Create a mock structure of folders and files | COMMENT |
| MEDIUM | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 687 | # Create an instance of the reader and set its config mock | COMMENT |
| MEDIUM | …tors/source-github/source_github/backoff_strategies.py | 22 | # This method is called if we run into the rate limit. GitHub limits requests to 5000 per hour and provides | COMMENT |
| MEDIUM | …lk/unit_tests/test_stream_reader_directory_matching.py | 169 | # Create a mock SFTP client | COMMENT |
| MEDIUM | …source-facebook-marketing/unit_tests/test_async_job.py | 742 | # Create a mock that always returns Job Failed status | COMMENT |
| MEDIUM | …source-facebook-marketing/unit_tests/test_async_job.py | 774 | # Create a mock that completes immediately but fails on get_result | COMMENT |
| MEDIUM | …source-facebook-marketing/unit_tests/test_async_job.py | 806 | # Create a mock that completes immediately and returns no IDs | COMMENT |
| MEDIUM | …source-facebook-marketing/unit_tests/test_async_job.py | 838 | # Create a mock that is always running (never completes) | COMMENT |
| MEDIUM | …ization/integration_tests/test_sparse_nested_fields.py | 88 | # Create the test folder with dbt project and appropriate destination settings to run integration tests from | COMMENT |
| MEDIUM | …base-normalization/integration_tests/test_ephemeral.py | 113 | # Create the test folder with dbt project and appropriate destination settings to run integration tests from | COMMENT |
| MEDIUM | …-normalization/integration_tests/test_normalization.py | 98 | # Create the test folder with dbt project and appropriate destination settings to run integration tests from | COMMENT |
| MEDIUM | …test_output/duckdb/test_nested_streams/dbt_project.yml | 1 | # This file is necessary to install dbt-utils with dbt deps | COMMENT |
| MEDIUM | …test_output/duckdb/test_simple_streams/dbt_project.yml | 1 | # This file is necessary to install dbt-utils with dbt deps | COMMENT |
| MEDIUM | …_test_output/mssql/test_nested_streams/dbt_project.yml | 1 | # This file is necessary to install dbt-utils with dbt deps | COMMENT |
| 17 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/bin/identify-dormant-workflows.py | 46 | CODE | |
| LOW | tools/bin/cleanup-workflow-runs.py | 48 | CODE | |
| LOW | …connectors/source-appsflyer/source_appsflyer/source.py | 104 | CODE | |
| LOW | …egrations/connectors/source-cart/source_cart/source.py | 88 | CODE | |
| LOW | …egrations/connectors/source-cart/source_cart/source.py | 92 | CODE | |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 252 | CODE | |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 42 | CODE | |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 331 | CODE | |
| LOW | …nnectors/source-linkedin-ads/unit_tests/test_source.py | 69 | CODE | |
| LOW | …/connectors/source-stock-ticker-api-tutorial/source.py | 156 | CODE | |
| LOW | …lob-storage/source_azure_blob_storage/stream_reader.py | 125 | CODE | |
| LOW | …stination-rabbitmq/destination_rabbitmq/destination.py | 40 | CODE | |
| LOW | …ions/connectors/source-shopify/source_shopify/utils.py | 136 | CODE | |
| LOW | …e-shopify/source_shopify/shopify_graphql/bulk/query.py | 855 | CODE | |
| LOW | …rce-shopify/source_shopify/shopify_graphql/bulk/job.py | 316 | CODE | |
| LOW | …ctors/source-shopify/source_shopify/streams/streams.py | 564 | CODE | |
| LOW | …ctors/source-shopify/source_shopify/streams/streams.py | 817 | CODE | |
| LOW | …/source-shopify/source_shopify/streams/base_streams.py | 271 | CODE | |
| LOW | …/source-shopify/source_shopify/streams/base_streams.py | 365 | CODE | |
| LOW | …endesk-chat/unit_tests/mock_server/response_builder.py | 346 | CODE | |
| LOW | …ation-amazon-sqs/destination_amazon_sqs/destination.py | 127 | CODE | |
| LOW | …rce-facebook-pages/source_facebook_pages/components.py | 82 | CODE | |
| LOW | …integrations/connectors/source-us-census/components.py | 52 | CODE | |
| LOW | …integrations/connectors/source-us-census/components.py | 159 | CODE | |
| LOW | …ogle-analytics-v4/source_google_analytics_v4/source.py | 285 | CODE | |
| LOW | …ogle-analytics-v4/source_google_analytics_v4/source.py | 338 | CODE | |
| LOW | …ation_pgvector/common/destinations/record_processor.py | 214 | CODE | |
| LOW | …ector/destination_pgvector/common/sql/sql_processor.py | 677 | CODE | |
| LOW | …ations/connectors/source-faker/source_faker/streams.py | 155 | CODE | |
| LOW | …s/connectors/source-commcare/source_commcare/source.py | 293 | CODE | |
| LOW | …e-integrations/connectors/source-klaviyo/components.py | 229 | CODE | |
| LOW | …ination-sftp-json/destination_sftp_json/destination.py | 17 | CODE | |
| LOW | …integrations/connectors/source-instagram/components.py | 304 | CODE | |
| LOW | …stination-firebolt/destination_firebolt/destination.py | 77 | CODE | |
| LOW | …ns/connectors/source-mixpanel/source_mixpanel/utils.py | 41 | CODE | |
| LOW | …nnectors/source-mixpanel/source_mixpanel/components.py | 179 | CODE | |
| LOW | …s/destination-sqlite/destination_sqlite/destination.py | 37 | CODE | |
| LOW | …tors/destination-vectara/destination_vectara/client.py | 171 | CODE | |
| LOW | …egrations/connectors/source-kyve/source_kyve/stream.py | 104 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 251 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 907 | CODE | |
| LOW | …-integrations/connectors/source-bing-ads/components.py | 142 | CODE | |
| LOW | …-integrations/connectors/source-bing-ads/components.py | 497 | CODE | |
| LOW | …-integrations/connectors/source-typeform/components.py | 27 | CODE | |
| LOW | …ination-couchbase/destination_couchbase/destination.py | 86 | CODE | |
| LOW | …ination-couchbase/destination_couchbase/destination.py | 214 | CODE | |
| LOW | …ination-couchbase/destination_couchbase/destination.py | 266 | CODE | |
| LOW | …ination-couchbase/destination_couchbase/destination.py | 345 | CODE | |
| LOW | …ination-couchbase/destination_couchbase/destination.py | 367 | CODE | |
| LOW | …ination-couchbase/destination_couchbase/destination.py | 387 | CODE | |
| LOW | …ns/connectors/source-firebolt/source_firebolt/utils.py | 76 | CODE | |
| LOW | …s/connectors/source-firebolt/source_firebolt/source.py | 81 | CODE | |
| LOW | …ions/connectors/source-fauna/source_fauna/serialize.py | 26 | CODE | |
| LOW | …rations/connectors/source-fauna/source_fauna/source.py | 206 | CODE | |
| LOW | …rations/connectors/source-fauna/source_fauna/source.py | 573 | CODE | |
| LOW | …ns/connectors/source-fauna/unit_tests/discover_test.py | 30 | CODE | |
| LOW | …-integrations/connectors/source-intercom/components.py | 57 | CODE | |
| LOW | …n-aws-datalake/destination_aws_datalake/destination.py | 36 | CODE | |
| LOW | …aws-datalake/destination_aws_datalake/stream_writer.py | 69 | CODE | |
| LOW | …aws-datalake/destination_aws_datalake/stream_writer.py | 118 | CODE | |
| 132 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM⚡ | …ors/source-iterable/unit_tests/test_lookback_window.py | 73 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ors/source-iterable/unit_tests/test_lookback_window.py | 75 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ors/source-iterable/unit_tests/test_lookback_window.py | 188 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ors/source-iterable/unit_tests/test_lookback_window.py | 190 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ors/source-iterable/unit_tests/test_lookback_window.py | 274 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …ors/source-iterable/unit_tests/test_lookback_window.py | 276 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 21 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 24 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 39 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 41 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 101 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 103 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 128 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 130 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 154 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …ors/source-iterable/unit_tests/test_lookback_window.py | 156 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/connectors/source-amazon-seller-partner/components.py | 132 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …/connectors/source-amazon-seller-partner/components.py | 134 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt | 44 | // ── helpers ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt | 70 | // ── validateTimestamp ──────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt | 112 | // ── validateInteger ───────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt | 161 | // ── validateNumber ────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt | 193 | // ── coerce ────────────────────────────────────────────────────────────────── | COMMENT |
| MEDIUM | …er-io/unit_tests/test_pagination_region_incremental.py | 229 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …er-io/unit_tests/test_pagination_region_incremental.py | 231 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/source-s3/unit_tests/v4/test_availability_strategy.py | 23 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/source-s3/unit_tests/v4/test_availability_strategy.py | 25 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/source-s3/unit_tests/v4/test_availability_strategy.py | 56 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/source-s3/unit_tests/v4/test_availability_strategy.py | 58 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/source-s3/unit_tests/v4/test_availability_strategy.py | 92 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/source-s3/unit_tests/v4/test_availability_strategy.py | 94 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/source-s3/unit_tests/v4/test_availability_strategy.py | 182 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/source-s3/unit_tests/v4/test_availability_strategy.py | 184 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …connectors/source-gcs/unit_tests/test_stream_reader.py | 200 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …connectors/source-gcs/unit_tests/test_stream_reader.py | 202 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …rations/enterprise-connectors/source-db2-enterprise.md | 112 | # =============================================== | COMMENT |
| MEDIUM | …rations/enterprise-connectors/source-db2-enterprise.md | 115 | # =============================================== | COMMENT |
| MEDIUM | .github/workflows/agent-sdk-docs-generate.yml | 149 | # ── Build symbol index ────────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/agent-sdk-docs-generate.yml | 165 | # ── Add anchors and resolve links ─────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/block-release.yml | 61 | # ── Validate inputs ────────────────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/block-release.yml | 69 | # ── Authenticate as Octavia Bot (creates PRs, triggers CI) ────── | COMMENT |
| MEDIUM⚡ | .github/workflows/block-release.yml | 90 | # ── Validate connector directory exists ───────────────────────── | COMMENT |
| MEDIUM⚡ | .github/workflows/block-release.yml | 99 | # ── Install airbyte-ops CLI ─────────────────────────────────── | COMMENT |
| MEDIUM⚡ | .github/workflows/block-release.yml | 106 | # ── Block: create marker file via CLI ──────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/block-release.yml | 117 | # ── Unblock: remove marker file via CLI ────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/block-release.yml | 128 | # ── Create and force-merge PR ────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/block-release.yml | 157 | # ── Force-merge using admin bot ──────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/block-release.yml | 188 | # ── Summary ──────────────────────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/hydra-automerge.yml | 54 | # ── Authentication ────────────────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/hydra-automerge.yml | 64 | # ── Pre-checks ───────────────────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/hydra-automerge.yml | 215 | # ── Devin AI evaluation ──────────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/hydra-automerge.yml | 261 | # ── Evaluate structured output ───────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/hydra-automerge.yml | 310 | # ── Post results ─────────────────────────────────────────────── | COMMENT |
| MEDIUM | .github/workflows/hydra-automerge.yml | 404 | # ── Merge (if evaluation passed and not dry-run) ──────────────── | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …nnectors/source-appsflyer/source_appsflyer/__init__.py | 8 | __all__ = ["SourceAppsflyer"] | CODE |
| LOW | …rations/connectors/source-cart/source_cart/__init__.py | 27 | __all__ = ["SourceCart", "CentralAPIHeaderAuthenticator", "CustomHeaderAuthenticator"] | CODE |
| LOW⚡ | …nnectors/source-linkedin-ads/unit_tests/test_source.py | 72 | def update_with_cache_parent_configs(parent_configs: list[dict[str, Any]]) -> None: | CODE |
| LOW | …egrations/connectors/source-rss/source_rss/__init__.py | 8 | __all__ = ["SourceRss"] | CODE |
| LOW | …ure-blob-storage/source_azure_blob_storage/__init__.py | 10 | __all__ = ["SourceAzureBlobStorage", "SourceAzureBlobStorageStreamReader", "SourceAzureBlobStorageSpec"] | CODE |
| LOW | …/source-commercetools/source_commercetools/__init__.py | 8 | __all__ = ["SourceCommercetools"] | CODE |
| LOW | …/destination-rabbitmq/destination_rabbitmq/__init__.py | 8 | __all__ = ["DestinationRabbitmq"] | CODE |
| LOW | …nnectors/destination-kvdb/destination_kvdb/__init__.py | 26 | __all__ = ["DestinationKvdb"] | CODE |
| LOW | …connectors/source-iterable/source_iterable/__init__.py | 3 | __all__ = ["SourceIterable"] | CODE |
| LOW | …e-shopify/unit_tests/integration/api/authentication.py | 16 | def set_up_shop(http_mocker: HttpMocker, shop_name: str) -> None: | CODE |
| LOW | …s/connectors/source-shopify/source_shopify/__init__.py | 27 | __all__ = ["SourceShopify"] | CODE |
| LOW⚡ | …rce-shopify/source_shopify/shopify_graphql/bulk/job.py | 218 | def _set_checkpointing(self) -> None: | CODE |
| LOW⚡ | …rce-shopify/source_shopify/shopify_graphql/bulk/job.py | 226 | def _set_last_checkpoint_cursor_value(self, checkpointed_cursor: str) -> None: | CODE |
| LOW | …-shopify/source_shopify/shopify_graphql/bulk/record.py | 125 | def _set_parent_state_value(self, value: str | int) -> None: | CODE |
| LOW | …tors/destination-chroma/destination_chroma/__init__.py | 8 | __all__ = ["DestinationChroma"] | CODE |
| LOW | …tination-amazon-sqs/destination_amazon_sqs/__init__.py | 8 | __all__ = ["DestinationAmazonSqs"] | CODE |
| LOW | …rations/connectors/source-okta/source_okta/__init__.py | 8 | __all__ = ["SourceOkta", "components"] | CODE |
| LOW | …tors/source-freshcaller/source_freshcaller/__init__.py | 8 | __all__ = ["SourceFreshcaller"] | CODE |
| LOW | …nnectors/source-couchbase/source_couchbase/__init__.py | 8 | __all__ = ["SourceCouchbase"] | CODE |
| LOW | …ource-facebook-pages/source_facebook_pages/__init__.py | 8 | __all__ = ["SourceFacebookPages"] | CODE |
| LOW | …e-outbrain-amplify/source_outbrain_amplify/__init__.py | 8 | __all__ = ["SourceOutbrainAmplify"] | CODE |
| LOW | …gle-sheets/unit_tests/integration/conftest/__init__.py | 11 | __all__ = [ | CODE |
| LOW | …tors/source-azure-table/source_azure_table/__init__.py | 8 | __all__ = ["SourceAzureTable"] | CODE |
| LOW | …le-analytics-v4/source_google_analytics_v4/__init__.py | 28 | __all__ = ["SourceGoogleAnalyticsV4"] | CODE |
| LOW | …/destination-pgvector/destination_pgvector/__init__.py | 8 | __all__ = ["DestinationPGVector"] | CODE |
| LOW | …ation_pgvector/common/destinations/record_processor.py | 300 | def _setup(self) -> None: # noqa: B027 # Intentionally empty, not abstract | CODE |
| LOW | …tions/connectors/source-faker/source_faker/__init__.py | 8 | __all__ = ["SourceFaker"] | CODE |
| LOW | …ectors/source-tplcentral/source_tplcentral/__init__.py | 28 | __all__ = ["SourceTplcentral"] | CODE |
| LOW | …s/connectors/source-zenloop/source_zenloop/__init__.py | 8 | __all__ = ["SourceZenloop"] | CODE |
| LOW | …connectors/source-commcare/source_commcare/__init__.py | 8 | __all__ = ["SourceCommcare"] | CODE |
| LOW | …e-integrations/connectors/source-klaviyo/components.py | 178 | def _set_recipient_count(self, record: Mapping[str, Any]) -> None: | CODE |
| LOW | …e-integrations/connectors/source-klaviyo/components.py | 190 | def _set_campaign_message(self, record: Mapping[str, Any]) -> None: | CODE |
| LOW | …estination-sftp-json/destination_sftp_json/__init__.py | 8 | __all__ = ["DestinationSftpJson"] | CODE |
| LOW | …e-google-directory/source_google_directory/__init__.py | 6 | __all__ = ["SourceGoogleDirectory"] | CODE |
| LOW | …ons/connectors/source-instagram/unit_tests/__init__.py | 7 | __all__ = ["get_source", "read_full_refresh", "read_incremental"] | CODE |
| LOW | …ectors/source-amazon-sqs/source_amazon_sqs/__init__.py | 9 | __all__ = ["SourceAmazonSqs"] | CODE |
| LOW | …/destination-firebolt/destination_firebolt/__init__.py | 8 | __all__ = ["DestinationFirebolt"] | CODE |
| LOW | …on-google-sheets/destination_google_sheets/__init__.py | 8 | __all__ = ["DestinationGoogleSheets"] | CODE |
| LOW | …s/connectors/source-genesys/source_genesys/__init__.py | 8 | __all__ = ["SourceGenesys"] | CODE |
| LOW | …ons/connectors/source-looker/source_looker/__init__.py | 3 | __all__ = ["SourceLooker"] | CODE |
| LOW | …ectors/destination-astra/destination_astra/__init__.py | 8 | __all__ = ["DestinationAstra"] | CODE |
| LOW | …tors/source-public-apis/source_public_apis/__init__.py | 8 | __all__ = ["SourcePublicApis"] | CODE |
| LOW | …connectors/source-mixpanel/source_mixpanel/__init__.py | 27 | __all__ = ["SourceMixpanel"] | CODE |
| LOW | …tors/destination-sqlite/destination_sqlite/__init__.py | 8 | __all__ = ["DestinationSqlite"] | CODE |
| LOW | …rs/destination-vectara/destination_vectara/__init__.py | 8 | __all__ = ["DestinationVectara"] | CODE |
| LOW | …rations/connectors/source-kyve/source_kyve/__init__.py | 8 | __all__ = ["SourceKyve"] | CODE |
| LOW | …-integrations/connectors/source-bing-ads/components.py | 28 | logger = logging.getLogger(__name__) | CODE |
| LOW | …crosoft-onedrive/source_microsoft_onedrive/__init__.py | 8 | __all__ = ["SourceMicrosoftOneDrive"] | CODE |
| LOW | …estination-couchbase/destination_couchbase/__init__.py | 8 | __all__ = ["DestinationCouchbase"] | CODE |
| LOW | …s/connectors/source-webflow/source_webflow/__init__.py | 8 | __all__ = ["SourceWebflow"] | CODE |
| LOW | …connectors/source-firebolt/source_firebolt/__init__.py | 8 | __all__ = ["SourceFirebolt"] | CODE |
| LOW | …e-box-data-extract/source_box_data_extract/__init__.py | 8 | __all__ = ["SourceBoxDataExtract"] | CODE |
| LOW | …tions/connectors/source-fauna/source_fauna/__init__.py | 8 | __all__ = ["SourceFauna"] | CODE |
| LOW | …ons/connectors/source-gridly/source_gridly/__init__.py | 8 | __all__ = ["SourceGridly"] | CODE |
| LOW | …tion-aws-datalake/destination_aws_datalake/__init__.py | 26 | __all__ = ["DestinationAwsDatalake"] | CODE |
| LOW | …ons/connectors/source-adjust/source_adjust/__init__.py | 8 | __all__ = ["SourceAdjust", "components"] | CODE |
| LOW | …tors/destination-deepset/destination_deepset/models.py | 16 | __all__ = [ | CODE |
| LOW | …rs/destination-deepset/destination_deepset/__init__.py | 9 | __all__ = ["DestinationDeepset"] | CODE |
| LOW | …ors/destination-deepset/unit_tests/test_destination.py | 68 | def _setup(monkeypatch: pytest.MonkeyPatch, client: DeepsetCloudApi) -> None: | CODE |
| LOW | …ectors/destination-ragie/destination_ragie/__init__.py | 10 | __all__ = ["DestinationRagie", "RagieWriter"] | CODE |
| 80 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …/source-news-api/integration_tests/invalid_config.json | 2 | "api_key": "YOUR_API_KEY", | CODE |
| HIGH | …s/source-news-api/integration_tests/sample_config.json | 2 | "api_key": "YOUR_API_KEY", | CODE |
| HIGH | …ctors/source-oura/integration_tests/sample_config.json | 2 | "api_key": "YOUR_API_KEY", | CODE |
| HIGH | …rce-alpha-vantage/integration_tests/sample_config.json | 2 | "api_key": "YOUR_API_KEY", | CODE |
| HIGH | …rce-northpass-lms/integration_tests/sample_config.json | 2 | "api_key": "your-api-key" | CODE |
| HIGH | …ntegrations/connectors/source-salesflare/manifest.yaml | 372 | description: "Enter you api key like this : Bearer YOUR_API_KEY" | CODE |
| HIGH | …stination-customer-io/src/main/resources/manifest.yaml | 28 | Enter your Customer IO <a href="https://docs.customer.io/integrations/sdk/ios/getting-started/auth/#get-yo | CODE |
| HIGH | …stination-customer-io/src/main/resources/manifest.yaml | 37 | Enter your Customer IO <a href="https://docs.customer.io/integrations/sdk/ios/getting-started/auth/#get-yo | CODE |
| HIGH | …/src/test-integration/resources/expected-spec-oss.json | 18 | "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-star | CODE |
| HIGH | …/src/test-integration/resources/expected-spec-oss.json | 26 | "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-star | CODE |
| HIGH | …rc/test-integration/resources/expected-spec-cloud.json | 18 | "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-star | CODE |
| HIGH | …rc/test-integration/resources/expected-spec-cloud.json | 26 | "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-star | CODE |
| HIGH | …/source-amplitude/integration_tests/sample_config.json | 3 | "api_key": "<your_api_key>", | CODE |
| HIGH | …rs/source-paypal-transaction/bin/payments_generator.py | 24 | # '{"actor":{"account_number":"<ACCOUNT_ID>","party_id":"<PARTY_ID>","auth_claims":["AUTHORIZATION_CODE"],"auth_state":" | COMMENT |
| HIGH | …urce-emailoctopus/integration_tests/sample_config.json | 2 | "api_key": "your_api_key" | CODE |
| HIGH | …/source-chargebee/integration_tests/sample_config.json | 3 | "site_api_key": "<your_api_key>", | CODE |
| HIGH | …/source-plausible/integration_tests/sample_config.json | 2 | "api_key": "your_api_key", | CODE |
| HIGH | …/source-coin-api/integration_tests/invalid_config.json | 2 | "api_key": "YOUR_API_KEY", | CODE |
| HIGH | …s/source-coin-api/integration_tests/sample_config.json | 2 | "api_key": "YOUR_API_KEY", | CODE |
| HIGH | docs/platform/enterprise-flex/log-collection.md | 162 | --set datadog.apiKey=<YOUR_API_KEY> \ | CODE |
| HIGH | docs/platform/enterprise-flex/log-collection.md | 162 | --set datadog.apiKey=<YOUR_API_KEY> \ | CODE |
| HIGH | docs/integrations/sources/recurly.md | 58 | Generate a API key using the [Recurly documentation](https://docs.recurly.com/docs/api-keys#section-find-or-generate-you | CODE |
| HIGH | docs/integrations/sources/mailchimp.md | 52 | - To authenticate using an API key for Airbyte Open Source, select **API key** from the Authentication dropdown and ente | CODE |
| HIGH | docs/integrations/sources/salesflare.md | 10 | | `api_key` | `string` | API Key. Enter you api key like this : Bearer YOUR_API_KEY | | | CODE |
| HIGH | …cs/developers/pyairbyte/reference/airbyte/mcp/index.md | 40 | AIRBYTE_CLOUD_CLIENT_ID=your_api_key | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …-auto-release/update-bulk-cdk-version-in-connectors.sh | 12 | # Check if merge_base could be found (e.g., if branches are unrelated) | COMMENT |
| LOW | …-auto-release/update-bulk-cdk-version-in-connectors.sh | 25 | # Check if any files were modified | COMMENT |
| LOW | tools/bin/cdk-auto-release/update-changelog.sh | 198 | # Check if awk actually produced output (basic sanity check) | COMMENT |
| LOW | tools/bin/cdk-auto-release/update-changelog.sh | 277 | # Check if there are changes to commit before committing | COMMENT |
| LOW | …/connectors/source-stock-ticker-api-tutorial/source.py | 145 | # Read the file named spec.json from the module directory as a JSON file | COMMENT |
| LOW | …ions/connectors/source-shopify/source_shopify/utils.py | 314 | # Check if we have the saved state and keep the minimun value | COMMENT |
| LOW | …/connectors/source-mixpanel/source_mixpanel/streams.py | 472 | # Set whether to allow additional properties for engage and export endpoints | COMMENT |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 241 | # Check if this is a token expiration error and invalidate the token if so | COMMENT |
| LOW | …ft-onedrive/source_microsoft_onedrive/stream_reader.py | 183 | # Check if the object is a file or a folder | COMMENT |
| LOW | …s/destination-couchbase/unit_tests/test_destination.py | 118 | # Check if collection was created | COMMENT |
| LOW | …s/destination-couchbase/unit_tests/test_destination.py | 121 | # Check if upsert_multi was called for writing records | COMMENT |
| LOW⚡ | …s/destination-couchbase/unit_tests/test_destination.py | 154 | # Check if collection was created | COMMENT |
| LOW⚡ | …s/destination-couchbase/unit_tests/test_destination.py | 157 | # Check if upsert_multi was called twice (once for the first 1000 records, once for the remaining) | COMMENT |
| LOW | …s/destination-couchbase/unit_tests/test_destination.py | 207 | # Check if collections were created for both streams | COMMENT |
| LOW | …s/destination-couchbase/unit_tests/test_destination.py | 212 | # Check if upsert_multi was called for both collections | COMMENT |
| LOW | …ination-couchbase/destination_couchbase/destination.py | 222 | # Check if collection exists | COMMENT |
| LOW | …ons/connectors/source-webflow/source_webflow/source.py | 274 | # Loop over the list of records and create a dictionary with name as key, and _id as value | COMMENT |
| LOW | …ce-box-data-extract/source_box_data_extract/box_api.py | 107 | # Check if any representations exist | COMMENT |
| LOW | …aws-datalake/destination_aws_datalake/stream_writer.py | 344 | # Check if nested object has properties and no mixed type objects | COMMENT |
| LOW | …ion-aws-datalake/integration_tests/integration_test.py | 155 | # Check if table was created | COMMENT |
| LOW | …ors/source-google-ads/unit_tests/test_empty_streams.py | 338 | # Check if this is a click_view query using regex (case-insensitive) | COMMENT |
| LOW | …onnectors/source-google-ads/source_google_ads/utils.py | 261 | # Check if the timeout has been reached without new results. | COMMENT |
| LOW | …paypal-transaction/bin/paypal_transaction_generator.py | 199 | # Check if the request was successful | COMMENT |
| LOW | …nation-surrealdb/integration_tests/integration_test.py | 49 | # Check if surreal command is available | COMMENT |
| LOW⚡ | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 320 | # Check if the file exists at the file_url path | COMMENT |
| LOW | …harepoint/source_microsoft_sharepoint/stream_reader.py | 219 | # Check if the object is a file or a folder | COMMENT |
| LOW | …harepoint/source_microsoft_sharepoint/stream_reader.py | 490 | # Write the file to the local directory | COMMENT |
| LOW | …s/destination-pinecone/destination_pinecone/indexer.py | 126 | # Check if adding the item exceeds the size limit | COMMENT |
| LOW | …/source-pinterest/unit_tests/test_config_migrations.py | 54 | # Check if the condition evaluates to true | COMMENT |
| LOW | …e-integrations/connectors/source-hubspot/components.py | 432 | # Set it to null to avoid errors on destination' normalization stage. | COMMENT |
| LOW | …ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py | 161 | # Check if dir_path could lead to matching files | COMMENT |
| LOW | …ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py | 174 | # Check if the directory exactly matches the pattern | COMMENT |
| LOW | …ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py | 188 | # Check if each directory part matches the corresponding glob part | COMMENT |
| LOW | …ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py | 196 | # Check if this part could match (including wildcards) | COMMENT |
| LOW⚡ | …r/test_search_analytics_keyword_site_report_by_page.py | 106 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW⚡ | …r/test_search_analytics_keyword_site_report_by_page.py | 281 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW | …r/test_search_analytics_keyword_site_report_by_page.py | 119 | # Check if this is a keyword site report by page request | COMMENT |
| LOW | …r/test_search_analytics_keyword_site_report_by_page.py | 348 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW⚡ | …ck_server/test_search_analytics_keyword_page_report.py | 108 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW⚡ | …ck_server/test_search_analytics_keyword_page_report.py | 312 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW | …ck_server/test_search_analytics_keyword_page_report.py | 121 | # Check if this is a keyword page report request | COMMENT |
| LOW | …ck_server/test_search_analytics_keyword_page_report.py | 268 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW | …ck_server/test_search_analytics_keyword_page_report.py | 379 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW⚡ | …r/test_search_analytics_keyword_site_report_by_site.py | 106 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW⚡ | …r/test_search_analytics_keyword_site_report_by_site.py | 302 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW | …r/test_search_analytics_keyword_site_report_by_site.py | 119 | # Check if this is a keyword site report by site request | COMMENT |
| LOW | …r/test_search_analytics_keyword_site_report_by_site.py | 368 | # Check if this is a parent stream request (search_appearances) | COMMENT |
| LOW | .claude/skills/my-prs/scripts/fetch-prs.sh | 64 | # Check if author is org member | COMMENT |
| LOW | poe-tasks/build-and-publish-java-connectors-with-tag.sh | 76 | # Check if this is a Java connector | COMMENT |
| LOW | poe-tasks/get-modified-connectors.sh | 164 | # Check if it's a Java connector (either with build.gradle or build.gradle.kts) | COMMENT |
| LOW | poe-tasks/publish-python-registry.sh | 36 | # Check if the connector is enabled for PyPI publishing | COMMENT |
| LOW | poe-tasks/publish-python-registry.sh | 164 | # Check if PyPI publishing is enabled in metadata | COMMENT |
| LOW | poe-tasks/publish-python-registry.sh | 206 | # Check if package already exists | COMMENT |
| LOW | .github/workflows/community-pr-permissions-check.yml | 42 | # Check if fork is from an organization | COMMENT |
| LOW | .github/workflows/stale-discussions-autoclose.yml | 80 | # Check if last comment is the housekeeping prompt and is older than 14 days | COMMENT |
| LOW | …hub/workflows/update-connector-cdk-version-command.yml | 67 | # Check if connector uses airbyteBulkConnector plugin | COMMENT |
| LOW | .github/workflows/ai-docs-review-command.yml | 140 | # Check if any files match the connector path pattern | COMMENT |
| LOW | .github/workflows/pr-ai-review-submit.yml | 148 | # Check if review was created successfully | COMMENT |
| LOW | .github/actions/connector-image-build-push/action.yml | 95 | # Check if connector directory exists | COMMENT |
| LOW | .github/actions/connector-image-build-push/action.yml | 101 | # Check if metadata.yaml exists | COMMENT |
| 1 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …te-integrations/connectors/source-pretix/manifest.yaml | 6 | [Pretix](https://pretix.eu/about/en/) connector enables seamless data | CODE |
| MEDIUM | …ntegrations/connectors/source-spotlercrm/manifest.yaml | 6 | The Airbyte connector for [Spotler CRM](https://spotler.com/) enables seamless | CODE |
| MEDIUM | …rce-shopify/source_shopify/shopify_graphql/bulk/job.py | 373 | # we leverage the checkpointing in this case. | COMMENT |
| MEDIUM | …yte-integrations/connectors/source-nocrm/manifest.yaml | 6 | [NoCRM](https://nocrm.io) connector enables seamless data integration between | CODE |
| MEDIUM | …ntegrations/connectors/source-amazon-ads/manifest.yaml | 3772 | # We've set the default to 12 so we can leverage some concurrency, but this can be tuned as we | COMMENT |
| MEDIUM | …tors/source-pabbly-subscriptions-billing/manifest.yaml | 7 | Billing](https://www.pabbly.com/subscriptions/) enables seamless data | CODE |
| LOW | …rations/connectors/source-fauna/source_fauna/source.py | 163 | # instead [:2] will just return an empty list. The first two values must match to | COMMENT |
| MEDIUM | …-integrations/connectors/source-flexmail/manifest.yaml | 6 | The Airbyte connector for [Flexmail](https://flexmail.be/) enables seamless | CODE |
| MEDIUM | …integrations/connectors/source-papersign/manifest.yaml | 7 | [Papersign](https://paperform.co/products/papersign/) enables seamless | CODE |
| LOW | …estination-ragie/integration_tests/test_integration.py | 169 | # If no real creds, just pass (mocked) | COMMENT |
| LOW | …estination-ragie/integration_tests/test_integration.py | 220 | # If no real creds, just pass (mocked) | COMMENT |
| MEDIUM | …ation-motherduck/destination_motherduck/destination.py | 417 | """Overridden from CDK base class in order to use the patched SerDes class.""" | STRING |
| MEDIUM | …e-integrations/connectors/source-campayn/manifest.yaml | 6 | The Airbyte connector for [Campayn](https://campayn.com/) enables seamless | CODE |
| MEDIUM | …integrations/connectors/source-paperform/manifest.yaml | 6 | Airbyte connector for [Paperform](https://paperform.co/) enables seamless data | CODE |
| MEDIUM | …rce-jina-ai-reader/source_jina_ai_reader/manifest.yaml | 142 | Visit https://coding.tools/url-encode for seamless encoding. | CODE |
| LOW | …ntegrations/connectors/source-prestashop/components.py | 139 | # If we don't have any fields to check, just return the record as is | COMMENT |
| LOW | …ons/connectors/source-s3/source_s3/v4/stream_reader.py | 205 | # we can simply return the result here as it is a context manager itself that will release all resources | COMMENT |
| LOW | …tegrations/connectors/source-s3/source_s3/v4/cursor.py | 135 | # Note: we convert to the v4 cursor granularity, but since no items are in the history we simply use the | COMMENT |
| MEDIUM | …nation-surrealdb/integration_tests/integration_test.py | 108 | # A more robust check (e.g., trying to connect) could be added if necessary. | COMMENT |
| MEDIUM | …-integrations/connectors/source-encharge/manifest.yaml | 6 | Airbyte connector for [Encharge](https://encharge.io/) enables seamless data | CODE |
| LOW | …on-http-tutorial/source_python_http_tutorial/source.py | 60 | # so we just return a list containing the response | COMMENT |
| MEDIUM | …yte-integrations/connectors/source-wufoo/manifest.yaml | 6 | The Airbyte connector for [Wufoo](https://www.wufoo.com/) enables seamless | CODE |
| LOW | …stination-timeplus/destination_timeplus/destination.py | 70 | # for append mode, just add more data to the existing stream. No need to do anything. | COMMENT |
| LOW | …rosoft-dataverse/source_microsoft_dataverse/streams.py | 101 | state_checkpoint_interval = None # For now we just use the change tracking as state, and it is only emitted on last | CODE |
| LOW | …integrations/bases/base-java/run_with_normalization.sh | 44 | # so if we remove the `write`, we can just pass the rest directly into normalization | COMMENT |
| LOW | poe-tasks/manifest-only-connector-tasks.toml | 8 | # manifest-only connector, simply add a `poe_tasks.toml` file in the connector's | COMMENT |
| MEDIUM | …c/main/kotlin/io/airbyte/cdk/load/data/AirbyteValue.kt | 76 | // They're not particularly robust, and probably shouldn't be relied on | COMMENT |
| MEDIUM | …ract/src/main/kotlin/io/airbyte/cdk/read/Partitions.kt | 184 | // pending state and stream status messages. This is done in order to better utilize sockets | COMMENT |
| MEDIUM | …c/main/kotlin/io/airbyte/cdk/load/data/AirbyteValue.kt | 76 | // They're not particularly robust, and probably shouldn't be relied on | COMMENT |
| MEDIUM | …/airbyte/cdk/integrations/base/IntegrationCliParser.kt | 16 | // todo (cgardens) - use argparse4j.github.io instead of org.apache.commons.cli to leverage better | COMMENT |
| LOW | …sources/types/ActorDefinitionResourceRequirements.yaml | 7 | # set to false because we need the validations on seeds to be strict. otherwise, we will just add whatever is in the see | COMMENT |
| LOW | …sources/types/ActorDefinitionResourceRequirements.yaml | 21 | # set to false because we need the validations on seeds to be strict. otherwise, we will just add whatever is in the | COMMENT |
| MEDIUM | …rations/destination/staging/GeneralStagingFunctions.kt | 24 | // leverage data that was uploaded to stage | COMMENT |
| MEDIUM⚡ | .github/workflows/autodoc.yml | 38 | fetch-depth: 0 # Full history needed for comprehensive analysis | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW⚡ | …ectors/source-google-ads/unit_tests/test_components.py | 990 | # Step 1: Serialize MESSAGE fields | COMMENT |
| LOW⚡ | …ectors/source-google-ads/unit_tests/test_components.py | 998 | # Step 2: Flatten nested dicts | COMMENT |
| LOW⚡ | …ource-sendgrid/unit_tests/mock_server/test_contacts.py | 38 | # Step 1: Mock the export creation request (POST) | COMMENT |
| LOW | …ource-sendgrid/unit_tests/mock_server/test_contacts.py | 49 | # Step 2: Mock the polling request (GET status) - return "ready" status | COMMENT |
| LOW | …ource-sendgrid/unit_tests/mock_server/test_contacts.py | 67 | # Step 3: Mock the download request - return plain CSV with uppercase field names | COMMENT |
| LOW⚡ | …urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java | 102 | // Step 1: Convert underscores to dashes (matches Debezium's normalizeName behavior) | COMMENT |
| LOW⚡ | …urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java | 105 | // Step 2: Replace special characters with underscores | COMMENT |
| LOW | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 376 | // Step 1: Create principal and retrieve OAuth credentials (clientId and clientSecret) | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 401 | // Step 2: Create principal role (realm-wide) and catalog role (catalog-specific) | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 405 | // Step 3: Link catalog role to principal role for the specific catalog | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 418 | // Step 4: Grant required privileges to the catalog role | COMMENT |
| LOW⚡ | …rations/destination/s3_data_lake/PolarisEnvironment.kt | 424 | // Step 5: Attach the principal role to the principal (completes the permission chain) | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 101 | // Step 1: Finalize the gzip CSV | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 116 | // Step 2: Upload to S3 | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 119 | // Step 3: Execute COPY | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 130 | // Step 4: Cleanup S3 staging file | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 142 | // Step 5: Reset state | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 219 | // Step 1: Resolve extended placeholders ({date:<format>}, {timestamp:millis|micro}) | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 241 | // Step 2: Resolve standard placeholders | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 252 | // Step 3: Ensure the file has the correct extension for Redshift COPY | COMMENT |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 229 | // Step 1: Materialize deduped rows into a session-scoped temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 232 | // Step 2: CDC hard-delete (if enabled) | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 251 | // Step 3: Update existing rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 254 | // Step 4: Insert new rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 257 | // Step 5: Drop temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 482 | // Step 1: Add temp column with the new type | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 484 | // Step 2: Cast data from old column to temp column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 486 | // Step 3: Record DESTINATION_TYPECAST_ERROR in _airbyte_meta for rows where | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 497 | // Step 4: Drop the original column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 499 | // Step 5: Rename temp column to the original name | STRING |
| LOW | …nectors/source-sftp-bulk/integration_tests/conftest.py | 52 | # Step 1: Extract the base CSV file from the ZIP archive | COMMENT |
| LOW | …nectors/source-sftp-bulk/integration_tests/conftest.py | 65 | # Step 2: Create duplicates with different names | COMMENT |
| LOW | …ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py | 172 | # we need to check if this directory could be part of a matching path | COMMENT |
| LOW⚡ | …dk/load/dataflow/transform/medium/ProtobufConverter.kt | 188 | // Step 1: Extract raw value from protobuf using the right method based on type | COMMENT |
| LOW⚡ | …dk/load/dataflow/transform/medium/ProtobufConverter.kt | 191 | // Step 2: Decide final target type (check for destination override first) | COMMENT |
| LOW⚡ | …dk/load/dataflow/transform/medium/ProtobufConverter.kt | 195 | // Step 3: Create AirbyteValue of the target type using the raw value | COMMENT |
| LOW⚡ | .github/workflows/autodoc.yml | 34 | # Step 1: Get the pushed code | COMMENT |
| LOW⚡ | .github/workflows/autodoc.yml | 40 | # Step 2: Analyze what files were changed in this push | COMMENT |
| LOW | .github/workflows/autodoc.yml | 77 | # Step 3: Check if this push affects a connector | COMMENT |
| LOW | .github/workflows/autodoc.yml | 109 | # Step 4: Trigger AI documentation update for connector changes | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | README.md | 39 | - **Giving AI agents, LLMs, or MCP clients real-time access to business data** (CRMs, support tools, SaaS APIs, database | CODE |
| MEDIUM | …ons/connectors/source-scaffold-java-jdbc/metadata.yaml | 24 | documentationUrl: https://docs.airbyte.com/integrations/sources/scaffold-java-jdbc | CODE |
| MEDIUM | docs/release_notes/self-managed/v-1.0.md | 35 | - [Workloads](/platform/understanding-airbyte/jobs#workloads) provide a more scalable and reliable architecture to run s | CODE |
| MEDIUM | docs/platform/understanding-airbyte/tech-stack.md | 47 | ### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_ | COMMENT |
| MEDIUM | docs/integrations/destinations/snowflake.md | 484 | | 1.0.5 | 2023-05-31 | [\#25782](https://github.com/airbytehq/airbyte/pull/25782) | Internal scaffolding for f | CODE |
| MEDIUM⚡ | docs/integrations/destinations/bigquery.md | 440 | | 1.5.2 | 2023-07-05 | [\#27936](https://github.com/airbytehq/airbyte/pull/27936) | Internal scaffolding change fo | CODE |
| MEDIUM⚡ | docs/integrations/destinations/bigquery.md | 443 | | 1.4.6 | 2023-06-28 | [\#27268](https://github.com/airbytehq/airbyte/pull/27268) | Internal scaffolding change fo | CODE |
| MEDIUM⚡ | docs/integrations/destinations/bigquery.md | 450 | | 1.3.4 | 2023-04-28 | [\#25588](https://github.com/airbytehq/airbyte/pull/25588) | Internal scaffolding change fo | CODE |
| MEDIUM⚡ | docs/integrations/destinations/bigquery.md | 452 | | 1.3.1 | 2023-04-20 | [\#25097](https://github.com/airbytehq/airbyte/pull/25097) | Internal scaffolding change fo | CODE |
| MEDIUM | …/operator-guides/using-the-airflow-airbyte-operator.md | 6 | # Using the Airbyte Operator to orchestrate Airbyte OSS | COMMENT |
| MEDIUM | …d_docs/version-1.7/understanding-airbyte/tech-stack.md | 47 | ### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_ | COMMENT |
| MEDIUM | …/operator-guides/using-the-airflow-airbyte-operator.md | 6 | # Using the Airbyte Operator to orchestrate Airbyte OSS | COMMENT |
| MEDIUM | …d_docs/version-1.8/understanding-airbyte/tech-stack.md | 47 | ### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_ | COMMENT |
| MEDIUM | …/operator-guides/using-the-airflow-airbyte-operator.md | 6 | # Using the Airbyte Operator to orchestrate Airbyte OSS | COMMENT |
| MEDIUM | …d_docs/version-1.6/understanding-airbyte/tech-stack.md | 47 | ### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_ | COMMENT |
| MEDIUM | …/operator-guides/using-the-airflow-airbyte-operator.md | 6 | # Using the Airbyte Operator to orchestrate Airbyte Core | COMMENT |
| MEDIUM | …d_docs/version-2.0/understanding-airbyte/tech-stack.md | 47 | ### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_ | COMMENT |
| MEDIUM | …/operator-guides/using-the-airflow-airbyte-operator.md | 6 | # Using the Airbyte Operator to orchestrate Airbyte Core | COMMENT |
| MEDIUM | …d_docs/version-2.1/understanding-airbyte/tech-stack.md | 47 | ### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_ | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …-shopify/source_shopify/shopify_graphql/bulk/record.py | 345 | Read the JSONL content saved from `job.job_retrieve_result()` line-by-line to avoid OOM. Args: | STRING |
| HIGH | …byte-integrations/connectors/source-jira/components.py | 255 | Removes key-value pairs with None values from specified nested dictionaries in a record. This transformation i | STRING |
| HIGH | …ft-onedrive/source_microsoft_onedrive/stream_reader.py | 141 | Retrieves a list of all nested files under the specified object. Args: drive_id: The ID of | STRING |
| HIGH | …ce-box-data-extract/source_box_data_extract/box_api.py | 69 | Performs a GET request to a Box API endpoint using the provided Box client. This is an internal helper functio | STRING |
| HIGH | …nectors/destination-deepset/destination_deepset/api.py | 94 | Upload file to deepset Cloud. Args: file (DeepsetCloudFile): The file to upload write_m | STRING |
| HIGH | …onnectors/source-google-ads/source_google_ads/utils.py | 347 | Splits a date range into smaller chunks based on the provided parameters. Args: start_date (str): The | STRING |
| HIGH | …ons/connectors/source-s3/source_s3/v4/stream_reader.py | 242 | Downloads a file from an S3 bucket to a specified local directory. Args: file (RemoteFile) | STRING |
| HIGH | …harepoint/source_microsoft_sharepoint/stream_reader.py | 170 | Retrieves a list of all nested files under the specified object. Args: drive_id: The ID of | STRING |
| HIGH | …rosoft-sharepoint/source_microsoft_sharepoint/utils.py | 44 | Executes a query with retry logic on encountering specific HTTP errors. This function attempts to execute `obj | STRING |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …ases/base-normalization/dbt-project-template/README.md | 15 | 1. You can also change directory (`cd /tmp/dev_root/workspace/1/0/normalize` for example) to one of the workspace genera | CODE |
| HIGH | docs/integrations/destinations/postgres.md | 268 | You may want to create objects that depend on the tables generated by Airbyte, such as views. If you | CODE |
| HIGH | docs/integrations/sources/devin-ai.md | 77 | | [Sessions Insights](https://docs.devin.ai/api-reference/v3/sessions/organizations-sessions-insights) | Full Refresh | | CODE |
| HIGH | docs/integrations/sources/devin-ai.md | 111 | | 0.2.0 | 2026-04-22 | [76475](https://github.com/airbytehq/airbyte/pull/76475) | Add `sessions_insights` stream for ana | CODE |
| HIGH | docs/community/contributing-to-airbyte/writing-docs.md | 14 | If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communi | CODE |
| HIGH | …cs/version-1.7/contributing-to-airbyte/writing-docs.md | 14 | If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communi | CODE |
| HIGH | …cs/version-1.8/contributing-to-airbyte/writing-docs.md | 14 | If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communi | CODE |
| HIGH | …cs/version-1.6/contributing-to-airbyte/writing-docs.md | 14 | If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communi | CODE |
| HIGH | …cs/version-2.0/contributing-to-airbyte/writing-docs.md | 14 | If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communi | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …e-integrations/connectors/source-klaviyo/manifest.yaml | 4593 | # Based on the above, the only threads that allow for slicing and hence might perform more concurrent HTTP requests are | COMMENT |
| HIGH | …c/test-integration/resources/nessie/docker-compose.yml | 97 | # In this example, Nessie is configured with 3 clients and 3 rules: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …rce-shopify/unit_tests/integration/test_bulk_stream.py | 206 | CODE | |
| LOW | …rce-shopify/unit_tests/integration/test_bulk_stream.py | 405 | CODE | |
| LOW | …rce-shopify/unit_tests/integration/test_bulk_stream.py | 410 | CODE | |
| LOW | …source-google-directory/source_google_directory/api.py | 75 | CODE | |
| LOW | …ions/connectors/source-youtube-analytics/components.py | 63 | CODE | |
| LOW | …/connectors/source-mixpanel/source_mixpanel/streams.py | 71 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 638 | CODE | |
| LOW | …-integrations/connectors/source-bing-ads/components.py | 601 | CODE | |
| LOW | …aws-datalake/destination_aws_datalake/config_reader.py | 80 | CODE | |
| LOW | …/source-pinterest/unit_tests/test_config_migrations.py | 62 | CODE | |
| LOW | …rch-console/unit_tests/mock_server/response_builder.py | 122 | CODE | |
| LOW | …rce_facebook_marketing/streams/base_insight_streams.py | 74 | CODE | |
| LOW | …tion/transform_catalog/destination_name_transformer.py | 307 | CODE | |
| LOW | …tion/transform_catalog/destination_name_transformer.py | 312 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | tools/bin/bulk-cdk/get-certified-connectors.sh | 9 | # Usage: | COMMENT |
| LOW | poe-tasks/repo-root-tasks.toml | 6 | # Example usage: | COMMENT |
| LOW | poe-tasks/repo-root-tasks.toml | 15 | # Example usage: | COMMENT |
| LOW | poe-tasks/gradle-connector-tasks.toml | 15 | # Example usage: | COMMENT |
| LOW | docs/check-docs-git-diff.sh | 12 | # Usage: | COMMENT |
| LOW | …ub/workflows/publish-connectors-prerelease-command.yml | 10 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ogle-analytics-v4/source_google_analytics_v4/spec.json | 107 | "description": "A JSON array describing the custom reports you want to sync from Google Analytics. See <a href=\ | CODE |
| MEDIUM | …rce_google_analytics_v4_service_account_only/spec.json | 67 | "description": "A JSON array describing the custom reports you want to sync from Google Analytics. See <a href=\ | CODE |
| LOW | …destination-cumulio/destination_cumulio/destination.py | 48 | # Instead, the connector will make sure to push the first batch of data as a "replace" action: this will cau | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | docusaurus/src/components/PyAirbyteExample.jsx | 42 | print(record)`}{" "} | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ectors/source-google-ads/unit_tests/test_components.py | 753 | CODE |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …/source/postgres/PostgresSourceJdbcPartitionFactory.kt | 499 | // TODO: implement split for cursor incremental partition | COMMENT |