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 summarizes scanner evidence for airbytehq/airbyte, a Python project with 22,202 GitHub stars. SynthScan examined 3,843,093 lines of code across 15081 source files, recording 10136 pattern matches distributed across 28 syntactic categories. The legacy adjusted pattern signal is 4.7 (Low pattern signal); it is not an authorship estimate.
Use the findings to ask whether maintainers can explain intent, verify dependencies, simplify unnecessary scaffolding, and focus review effort. Risk Payload v1 adds ownership, supply-chain, over-engineering, and review-effort vectors when available. These are prompts for human verification, not probabilities, security findings, or measured maintenance costs.
Use each vector to guide manual verification of the underlying findings.
Can maintainers explain intent, assumptions, and trade-offs? 7220 finding(s).
Are imports declared and package/API names verified? 1219 finding(s).
Are wrappers, guards, and repeated structures necessary? 7241 finding(s).
Which changes need focused human review? 10136 finding(s).
This chart tracks the legacy adjusted pattern score across scan runs. Changes can reflect source changes, scan coverage, or detector/scoring versions; they do not measure AI adoption or prove that a team refactored code. Compare runs only when their scoring versions are compatible. The dashed line tracks the raw pattern-hit count.
Groups findings by configured severity weight. Severity is not a confidence estimate, security rating, or proof that a package is missing. Verify imports against the project's manifests and inspect each finding in its local design context.
This horizontal bar chart shows where configured pattern scores accumulate across directories. Treat the bars as locations to inspect, not as evidence of authorship or code quality. Use the file-level findings to decide whether a directory needs a focused ownership, dependency, complexity, or review check.
The scanner identified 10136 distinct pattern matches across 28 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a detector match to inspect in context. 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 configured finding weight (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — legacy comment-context matches receive a ×1.5 score weight. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier under the legacy scoring model.
| 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 |
| 1092 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| LOW | …ions/connectors/source-strava/unit_tests/test_oauth.py | 55 | def test_token_expiry_and_rotated_refresh_token_are_persisted(config, capsys): | CODE |
| LOW | …ions/connectors/source-strava/unit_tests/test_oauth.py | 89 | def test_check_validates_activity_permissions(config, activity_status, expected): | CODE |
| 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 | …grations/connectors/source-zoom/unit_tests/conftest.py | 37 | def clear_cache_before_each_test(): | CODE |
| LOW | …onnectors/source-zoom/unit_tests/test_authenticator.py | 68 | def test_manifest_has_no_custom_components(): | CODE |
| LOW | …onnectors/source-zoom/unit_tests/test_authenticator.py | 77 | def test_token_is_requested_with_account_credentials_grant_and_used_as_bearer(): | CODE |
| LOW | …onnectors/source-zoom/unit_tests/test_authenticator.py | 110 | def test_invalid_credentials_raise_config_error(status_code, error_body): | CODE |
| LOW | …onnectors/source-zoom/unit_tests/test_authenticator.py | 123 | def test_check_fails_on_invalid_credentials(): | CODE |
| LOW | …onnectors/source-zoom/unit_tests/test_authenticator.py | 144 | def test_every_requester_uses_the_shared_authenticator_and_token_refresh_handler(): | CODE |
| LOW | …onnectors/source-zoom/unit_tests/test_authenticator.py | 167 | def test_token_expired_mid_sync_is_refreshed_and_request_retried(_sleep): | CODE |
| LOW | …onnectors/source-zoom/unit_tests/test_authenticator.py | 187 | def test_token_expired_mid_sync_is_refreshed_behind_a_composite_error_handler(_sleep): | CODE |
| LOW | …nnectors/source-zoom/unit_tests/test_error_handling.py | 214 | def test_report_webinar_participants_double_encodes_uuid(self, http_mocker: HttpMocker): | CODE |
| LOW | …nnectors/source-zoom/unit_tests/test_error_handling.py | 314 | def test_past_webinar_streams_double_encode_uuid(stream_name, path, body): | CODE |
| LOW | …source-incident-io/unit_tests/test_alerting_streams.py | 18 | def test_paginated_alerting_streams_follow_cursor(stream_name, page_size): | CODE |
| LOW | …source-incident-io/unit_tests/test_alerting_streams.py | 46 | def test_alert_routes_stops_after_trailing_empty_page(): | CODE |
| LOW | …source-incident-io/unit_tests/test_alerting_streams.py | 69 | def test_alert_sources_removes_secret_token(): | CODE |
| LOW | …source-incident-io/unit_tests/test_alerting_streams.py | 91 | def test_incident_alerts_are_unpartitioned(): | CODE |
| LOW⚡ | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 530 | def test_spec_time_window_accepts_whole_days_only(value, valid): | CODE |
| LOW⚡ | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 537 | def test_num_workers_config_reads_a_stream(num_workers): | CODE |
| LOW⚡ | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 547 | def test_users_requests_inactive_users(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 93 | def test_stream_queries_every_incident_mode(stream_name, path, records_field): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 123 | def test_stream_stops_after_single_page(stream_name, path, records_field): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 140 | def test_follow_ups_record_keeps_category(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 155 | def test_check_uses_incidents_stream(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 171 | def test_incidents_requests_all_status_categories(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 198 | def test_incremental_sends_a_date_range_window_and_keeps_full_timestamp(stream_name, path, records_field): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 238 | def test_per_partition_state_sets_each_mode_filter(stream_name, path, records_field): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 266 | def test_start_date_config_starts_the_first_window(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 286 | def test_page_sizes_match_what_the_api_serves(stream_name, path, records_field, expected): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 301 | def test_full_refresh_without_start_date_reads_everything(stream_name, path, records_field): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 350 | def test_time_window_config_changes_the_slice_size(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 364 | def test_missing_scope_is_a_config_error_naming_the_scope(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 477 | def test_fail_responses_surface_the_manifest_messages(status, body, failure_type, expected): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 487 | def test_rate_limit_waits_for_retry_after_then_succeeds(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 506 | def test_spec_exposes_num_workers_within_the_max_concurrency(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 609 | def test_incident_attachments_retries_transient_errors(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 634 | def test_incident_attachments_error_handler_reuses_base_filters(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 659 | def test_catalog_entries_partitions_and_follows_all_pages(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 685 | def test_catalog_resources_records_are_keyed_by_type(): | CODE |
| LOW | …ctors/source-incident-io/unit_tests/test_v3_streams.py | 698 | def test_custom_field_options_partitions_and_follows_all_pages(): | CODE |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 41 | def _is_data_volume_rate_limit(response_or_exception: Optional[Union[requests.Response, Exception]]) -> bool: | CODE |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 210 | def transform_change_audit_stamps( | CODE |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 297 | def transform_targeting_criteria(record: Dict, dict_key: str = "targetingCriteria") -> Mapping[str, Any]: | CODE |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 485 | def transform_campaign_statistics_pivot_values(record: Dict) -> Mapping[str, Any]: | CODE |
| LOW | …nectors/source-linkedin-ads/unit_tests/test_streams.py | 34 | def test_analytics_stream_slices(requests_mock): | CODE |
| LOW | …nectors/source-linkedin-ads/unit_tests/test_streams.py | 78 | def test_analytics_stream_batches_entities_at_manifest_limit( | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 45 | def mock_analytics_cursor_params(): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 60 | def test_safe_http_client_create_prepared_request(components_module): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 79 | def test_safe_encode_http_requester_post_init(components_module): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 97 | def test_linkedin_ads_record_extractor_extract_records(components_module, mock_response): | CODE |
| LOW | …tors/source-linkedin-ads/unit_tests/test_components.py | 114 | def test_date_str_from_date_range(components_module): | CODE |
| 5468 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 | 183 | assert commits._stream_partition_generator._partition_factory._retriever.requester.get_request_params() == {"with_st | CODE |
| CRITICAL | …grations/source/bigquery/BigQueryConcurrentReadTest.kt | 107 | .joinToString("\n") { io.airbyte.cdk.util.Jsons.writeValueAsString(it) } | CODE |
| CRITICAL | …integrations/source/dynamodb/DynamoDbSourceReadTest.kt | 994 | software.amazon.awssdk.core.SdkBytes.fromByteArray(value.binaryValue()) | 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 | …ns/connectors/source-twilio/unit_tests/test_streams.py | 484 | message.state.stream.stream_state.__dict__.get("date_generated") | 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 | 30 | 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 | 55 | io.airbyte.cdk.load.schema.model.ColumnSchema( | CODE |
| CRITICAL⚡ | …connectors/source-pinterest/unit_tests/test_streams.py | 77 | 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⚡ | …/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 | 1133 | # Step 1: Serialize MESSAGE fields | COMMENT |
| LOW⚡ | …ectors/source-google-ads/unit_tests/test_components.py | 1141 | # 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 | 102 | // Step 1: Finalize the gzip CSV | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 117 | // Step 2: Upload to S3 | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 120 | // Step 3: Execute COPY | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 131 | // Step 4: Cleanup S3 staging file | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 143 | // Step 5: Reset state | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 220 | // Step 1: Resolve extended placeholders ({date:<format>}, {timestamp:millis|micro}) | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 242 | // Step 2: Resolve standard placeholders | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 253 | // Step 3: Ensure the file has the correct extension for Redshift COPY | COMMENT |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 233 | // Step 1: Materialize deduped rows into a session-scoped temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 236 | // Step 2: CDC hard-delete (if enabled) | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 255 | // Step 3: Update existing rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 258 | // Step 4: Insert new rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 261 | // Step 5: Drop temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 487 | // Step 1: Add temp column with the new type | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 489 | // Step 2: Cast data from old column to temp column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 491 | // Step 3: Record DESTINATION_TYPECAST_ERROR in _airbyte_meta for rows where | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 502 | // Step 4: Drop the original column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 504 | // 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 | 63 | ## Step 2: Get an access token | COMMENT |
| LOW | docs/platform/using-airbyte/configuring-api-access.md | 150 | ## 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 |
| 493 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 | …nnectors/source-zoom/unit_tests/test_error_handling.py | 20 | CODE | |
| LOW | …nnectors/source-zoom/unit_tests/test_error_handling.py | 20 | 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 | …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 | 19 | 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 | 44 | 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 | |
| 620 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/bulk-cdk/auto-upgrade/build-slack-summary.sh | 1 | #!/usr/bin/env bash | 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 | 1941 | # I looked into our test account to establish some baselines, but it seems like each endpoint | 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 | …/connectors/source-youtube-data/unit_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 | …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 |
| 587 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 | 735 | return """{"__typename":"FulfillmentOrder","id":"gid:\/\/shopify\/FulfillmentOrder\/2","fulfillAt":"2023-04-24T18:00 | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 737 | {"__typename":"FulfillmentOrderMerchantRequest","id":"gid:\/\/shopify\/FulfillmentOrderMerchantRequest\/333","message":n | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 742 | 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 | 743 | {"__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 | 748 | 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 | 763 | {"__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 | 768 | return """{"__typename":"ProductVariant","id":"gid:\/\/shopify\/ProductVariant\/40091751448765","title":"Metal","pri | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 769 | {"__typename":"ProductVariantPricePair","price":{"amount":"64.0","currencyCode":"USD"},"compareAtPrice":null,"__parentId | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 770 | {"__typename":"ProductVariant","id":"gid:\/\/shopify\/ProductVariant\/41561955827901","title":"Test Variant 1","price":" | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 771 | {"__typename":"ProductVariantPricePair","price":{"amount":"19.0","currencyCode":"USD"},"compareAtPrice":null,"__parentId | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 776 | return """{"__typename":"InventoryItem","id":"gid:\/\/shopify\/InventoryItem\/44871665713341","harmonizedSystemCode" | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 777 | {"__typename":"InventoryItem","id":"gid:\/\/shopify\/InventoryItem\/45419395743933","harmonizedSystemCode":"330510","pro | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 783 | {"__typename":"Customer","id":"gid:\/\/shopify\/Customer\/456","defaultAddress":{"id":"gid:\/\/shopify\/MailingAddress\/ | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 788 | 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 | 794 | {"__typename":"InventoryLevel","id":"gid:\/\/shopify\/InventoryLevel\/97912455357?inventory_item_id=42185200631997","can | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 795 | {"__typename":"InventoryLevel","id":"gid:\/\/shopify\/InventoryLevel\/97912455357?inventory_item_id=42185218719933","can | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 800 | return """{"__typename":"DiscountCodeNode","id":"gid:\/\/shopify\/DiscountCodeNode\/945205379261","codeDiscount":{"_ | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 801 | {"__typename":"DiscountRedeemCode","usageCount":0,"code":"HZAVNV2487WC","id":"gid:\/\/shopify\/DiscountRedeemCode\/11545 | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 802 | {"__typename":"DiscountRedeemCode","usageCount":0,"code":"SUMMERSALE10OFF","id":"gid:\/\/shopify\/DiscountRedeemCode\/13 | CODE |
| HIGH⚡ | …tions/connectors/source-shopify/unit_tests/conftest.py | 828 | return """{"__typename":"Order","id":"gid:\/\/shopify\/Order\/4554821468349","currency":"USD","transactions":[{"id": | CODE |
| HIGH | …ns/connectors/source-shopify/unit_tests/test_source.py | 808 | A 200 response with GraphQL `errors` has no usable page (`data` absent, null, or partial per GraphQL spec 7.1.2): | STRING |
| 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 | 27 | 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 | …zon-ads/unit_tests/integrations/test_report_streams.py | 841 | A PK naming a field the schema does not declare dedupes on a value that is always null, which | STRING |
| 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 | …omer-io/unit_tests/test_people_and_delivery_streams.py | 29 | # Empty suppression lists come back as null, without a category (live). | 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 | 273 | 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 | 109 | # Netsuite schemas do not specify if fields can be null, or not | COMMENT |
| HIGH | …e-integrations/connectors/source-hubspot/components.py | 953 | {"typeId": 3, "category": "HUBSPOT_DEFINED", "label": null} | STRING |
| HIGH | …e-integrations/connectors/source-hubspot/components.py | 962 | {"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 | 988 | f"listId should be a string to match the schema type [null, string], " | CODE |
| HIGH⚡ | …s/connectors/source-hubspot/unit_tests/test_streams.py | 957 | schema as [null, string]) can serialize the records without union-resolution failures. | STRING |
| HIGH⚡ | …s/connectors/source-hubspot/unit_tests/test_streams.py | 961 | 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 |
| HIGH | …ectors/source-uptick/unit_tests/test_error_handling.py | 63 | 200, '{"results": [{"task_id": 1, "updated": "2024-01-01T00:00:00.000000+0000"}], "links": {"next": null}}' | CODE |
| 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 | …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 | 46 | 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 | 58 | except Exception as e: | CODE |
| LOW | …connectors/source-couchbase/source_couchbase/source.py | 69 | 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 | 84 | except Exception as ex: | CODE |
| LOW | …ector/destination_pgvector/common/sql/sql_processor.py | 311 | 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 | 261 | 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 | 84 | 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 | 324 | except Exception as e: | CODE |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 420 | except Exception as e: | CODE |
| 225 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 | 18 | 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 | 34 | "email": "user@example.com", | CODE |
| LOW | …nnectors/source-iterable/unit_tests/test_extractors.py | 51 | "email": "user@example.com", | CODE |
| LOW | …nnectors/source-iterable/unit_tests/test_extractors.py | 82 | "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 | …unit_tests/mock_server/test_replay_session_activity.py | 143 | "visitor_name": "Jane Doe", | 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 | …nnectors/source-smsmode-rcs/unit_tests/test_streams.py | 13 | TEST_CONFIG = {"api_key": "fake-key"} | CODE |
| LOW | …nnectors/source-smsmode-rcs/unit_tests/test_streams.py | 52 | assert mock.last_request.headers["X-Api-Key"] == "fake-key" | 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 | 460 | 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 | 538 | 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 |
| 214 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 | 133 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM | …/connectors/source-amazon-seller-partner/components.py | 135 | # ------------------------------------------------------------------ | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 104 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 106 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 122 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 124 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 163 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 165 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 203 | # -------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …tors/source-metricool/unit_tests/test_brands_stream.py | 205 | # -------------------------------------------------------------------------- | 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 | 233 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …connectors/source-gcs/unit_tests/test_stream_reader.py | 235 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/connectors/source-netsuite/unit_tests/test_streams.py | 453 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/connectors/source-netsuite/unit_tests/test_streams.py | 455 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/connectors/source-netsuite/unit_tests/test_streams.py | 472 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM⚡ | …/connectors/source-netsuite/unit_tests/test_streams.py | 474 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/connectors/source-netsuite/unit_tests/test_streams.py | 315 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/connectors/source-netsuite/unit_tests/test_streams.py | 317 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/connectors/source-netsuite/unit_tests/test_streams.py | 365 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/connectors/source-netsuite/unit_tests/test_streams.py | 367 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/connectors/source-netsuite/unit_tests/test_streams.py | 407 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …/connectors/source-netsuite/unit_tests/test_streams.py | 409 | # --------------------------------------------------------------------------- | COMMENT |
| MEDIUM | …e-integrations/connectors/source-hubspot/manifest.yaml | 1449 | # ── Flows (Automation v4) ───────────────────────────────────────── | COMMENT |
| MEDIUM | …e-integrations/connectors/source-hubspot/manifest.yaml | 2448 | # ── Web Analytics base definition ───────────────────────────────── | COMMENT |
| MEDIUM | …e-integrations/connectors/source-hubspot/manifest.yaml | 2517 | # ── 12 Web Analytics stream definitions ──────────────────────────── | COMMENT |
| MEDIUM⚡ | …ource-hubspot/unit_tests/test_web_analytics_streams.py | 152 | # ── Test 1 & 2: Discovery gating ─────────────────────────────────── | COMMENT |
| MEDIUM | …ource-hubspot/unit_tests/test_web_analytics_streams.py | 215 | # ── Test: Event type router definition in manifest ────────────────── | COMMENT |
| MEDIUM | …ource-hubspot/unit_tests/test_web_analytics_streams.py | 261 | # ── Test 6: Pagination follows paging.next.after ──────────────────── | COMMENT |
| MEDIUM | …ource-hubspot/unit_tests/test_web_analytics_streams.py | 288 | # ── Test 7: Records extracted from results ────────────────────────── | COMMENT |
| 21 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 | 14678 | # 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 | 197 | # Create a queue to store output messages | COMMENT |
| MEDIUM | …ector/destination_pgvector/common/sql/sql_processor.py | 913 | # Create a dictionary mapping columns in users_final to users_stage for updating | STRING |
| MEDIUM | …ector/destination_pgvector/common/sql/sql_processor.py | 932 | # Define a join between temp_table and final_table | STRING |
| MEDIUM | …ector/destination_pgvector/common/sql/sql_processor.py | 935 | # 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 | 38 | # Create a stream with proper AirbyteStream object | COMMENT |
| MEDIUM | …connectors/source-google-ads/unit_tests/test_source.py | 244 | # 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 | 401 | # Create a dummy catalog to check if the SQL processor works | COMMENT |
| MEDIUM | …tors/source-salesforce/source_salesforce/exceptions.py | 20 | # 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 | 929 | # Create a dictionary mapping columns in users_final to users_stage for updating | STRING |
| MEDIUM | …stination_snowflake_cortex/common/sql/sql_processor.py | 948 | # Define a join between temp_table and final_table | STRING |
| MEDIUM | …stination_snowflake_cortex/common/sql/sql_processor.py | 951 | # 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 | 58 | # Create an instance of the extractor | COMMENT |
| MEDIUM | …s/source-zendesk-support/unit_tests/test_components.py | 91 | # 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 | 334 | # 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 | 357 | # Create a mock response for requests.head | COMMENT |
| MEDIUM | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 401 | # Create a mock structure of folders and files | COMMENT |
| MEDIUM | …-microsoft-sharepoint/unit_tests/test_stream_reader.py | 689 | # Create an instance of the reader and set its config mock | 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 |
| MEDIUM | …_test_output/mssql/test_simple_streams/dbt_project.yml | 1 | # This file is necessary to install dbt-utils with dbt deps | COMMENT |
| 16 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 | 297 | CODE | |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 60 | CODE | |
| LOW | …egrations/connectors/source-linkedin-ads/components.py | 376 | CODE | |
| LOW | …nnectors/source-linkedin-ads/unit_tests/test_source.py | 77 | 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 | …urce-shopify/unit_tests/test_schema_datetime_format.py | 37 | CODE | |
| LOW | …ions/connectors/source-shopify/source_shopify/utils.py | 144 | CODE | |
| LOW | …e-shopify/source_shopify/shopify_graphql/bulk/query.py | 855 | CODE | |
| LOW | …rce-shopify/source_shopify/shopify_graphql/bulk/job.py | 353 | CODE | |
| LOW | …ctors/source-shopify/source_shopify/streams/streams.py | 593 | CODE | |
| LOW | …ctors/source-shopify/source_shopify/streams/streams.py | 843 | CODE | |
| LOW | …/source-shopify/source_shopify/streams/base_streams.py | 272 | CODE | |
| LOW | …/source-shopify/source_shopify/streams/base_streams.py | 366 | 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 | 224 | CODE | |
| LOW | …ector/destination_pgvector/common/sql/sql_processor.py | 685 | 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 | 230 | CODE | |
| LOW | …s/source-klaviyo/unit_tests/test_start_date_default.py | 25 | 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 | …egrations/connectors/source-kyve/source_kyve/stream.py | 104 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 252 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 1274 | 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 | |
| 136 more matches not shown… | ||||
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| HIGH | …connectors/source-appsflyer/source_appsflyer/source.py | 116 | except ValueError: | CODE |
| HIGH | …rations/connectors/source-rss/source_rss/components.py | 43 | except (AttributeError, KeyError): | CODE |
| HIGH | …rations/connectors/source-rss/source_rss/components.py | 36 | except (AttributeError, KeyError): | CODE |
| HIGH | …y/source_shopify/shopify_graphql/bulk/external_sort.py | 135 | except FileNotFoundError: | CODE |
| HIGH | …/connectors/source-mixpanel/source_mixpanel/streams.py | 366 | except ValueError: | CODE |
| HIGH | …/connectors/source-mixpanel/source_mixpanel/streams.py | 421 | except ValueError: | CODE |
| HIGH | …nnectors/source-mixpanel/source_mixpanel/components.py | 347 | except ValueError: | CODE |
| HIGH | …nnectors/source-mixpanel/source_mixpanel/components.py | 210 | except KeyError: | CODE |
| HIGH | …/connectors/source-amazon-seller-partner/components.py | 280 | except (json.JSONDecodeError, AttributeError, TypeError): | CODE |
| HIGH | …/connectors/source-amazon-seller-partner/components.py | 832 | except (ValueError, TypeError): | CODE |
| HIGH | …/connectors/source-amazon-seller-partner/components.py | 1088 | except (OSError, EOFError, gzip.BadGzipFile): | CODE |
| HIGH | …/connectors/source-amazon-seller-partner/components.py | 441 | except ValueError: | CODE |
| HIGH | …/connectors/source-amazon-seller-partner/components.py | 461 | except ValueError: | CODE |
| HIGH | …/connectors/source-amazon-seller-partner/components.py | 532 | except ValueError: | CODE |
| HIGH | …-integrations/connectors/source-bing-ads/components.py | 290 | except ValueError: | CODE |
| HIGH | …connectors/source-fauna/unit_tests/incremental_test.py | 381 | except ValueError: | CODE |
| HIGH | …onnectors/source-fauna/unit_tests/full_refresh_test.py | 320 | except ValueError: | CODE |
| HIGH | …ination-weaviate/integration_tests/integration_test.py | 34 | except docker.errors.NotFound: | CODE |
| HIGH | …te-integrations/connectors/source-twilio/components.py | 40 | except ValueError: | CODE |
| HIGH | …ntegrations/connectors/source-prestashop/components.py | 126 | except (ValueError, AttributeError): | CODE |
| HIGH | …-integrations/connectors/source-s3/source_s3/stream.py | 64 | except KeyError: | CODE |
| HIGH | …ource-paypal-transaction/unit_tests/test_components.py | 90 | except requests.exceptions.HTTPError: | CODE |
| HIGH | …onnectors/source-linnworks/source_linnworks/streams.py | 233 | except FileNotFoundError: | CODE |
| HIGH | …connectors/source-linnworks/source_linnworks/source.py | 85 | except Exception: | CODE |
| HIGH | …nation-typesense/integration_tests/integration_test.py | 59 | except Exception: | CODE |
| HIGH | …ination-typesense/destination_typesense/destination.py | 62 | except Exception: | CODE |
| HIGH | …integrations/connectors/source-freshdesk/components.py | 45 | except ValueError: | CODE |
| HIGH | …integrations/connectors/source-pinterest/components.py | 96 | except Exception: | CODE |
| HIGH | …e-integrations/connectors/source-hubspot/components.py | 552 | except ValueError: | CODE |
| HIGH | …e-integrations/connectors/source-hubspot/components.py | 557 | except (ValueError, TypeError, OverflowError) as ex: | CODE |
| HIGH | …ot/unit_tests/integrations/request_builders/streams.py | 74 | except Exception: | CODE |
| HIGH | …github/unit_tests/test_manifest_repositories_stream.py | 108 | except Exception: # noqa: BLE001 - the failure itself is asserted through the trace messages | CODE |
| HIGH | …base-normalization/unit_tests/test_transform_config.py | 201 | except ValueError: | CODE |
| HIGH | …base-normalization/unit_tests/test_transform_config.py | 210 | except ValueError: | CODE |
| HIGH | …ctors/ci_credentials/ci_credentials/secrets_manager.py | 181 | except Exception: | CODE |
| 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 | 80 | 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 | 235 | def _set_checkpointing(self) -> None: | CODE |
| LOW⚡ | …rce-shopify/source_shopify/shopify_graphql/bulk/job.py | 245 | 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 | 322 | 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 | 179 | def _set_recipient_count(self, record: Mapping[str, Any]) -> None: | CODE |
| LOW | …e-integrations/connectors/source-klaviyo/components.py | 191 | 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 |
| 79 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 | 164 | --set datadog.apiKey=<YOUR_API_KEY> \ | CODE |
| HIGH | docs/platform/enterprise-flex/log-collection.md | 164 | --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/smsmode-rcs.md | 10 | - A smsmode API key. See [Get your API key](#get-your-api-key). | 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 | 322 | # 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 | 242 | # 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 | 322 | # 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 | 478 | # 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 | 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 | 213 | # 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 |
| LOW | .github/actions/connector-image-build-push/action.yml | 131 | # Check if this is a release candidate | COMMENT |
| 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 | 419 | # 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 | 4446 | # 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 | 422 | """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 |
| MEDIUM | …agents/skills/source-postgres-e2e-tests/scripts/run.sh | 2 | # PostgreSQL engine shim; orchestration lives in db-harness-lib. | COMMENT |
| 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 | …gents/skills/source-snowflake-e2e-tests/scripts/run.sh | 2 | # Snowflake engine shim; orchestration lives in db-harness-lib. | 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 | …l/.agents/skills/source-mssql-e2e-tests/scripts/run.sh | 2 | # MSSQL engine shim; orchestration lives in db-harness-lib. | 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 | …ents/skills/source-mongodb-v2-e2e-tests/scripts/run.sh | 2 | # MongoDB engine shim; orchestration lives in db-harness-lib. | COMMENT |
| MEDIUM | …kills/source-mongodb-v2-e2e-tests/scripts/apply-sql.sh | 4 | # The name follows the db-harness-lib engine contract (apply-sql.sh), but | 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 |
| MEDIUM | …l/.agents/skills/source-mysql-e2e-tests/scripts/run.sh | 2 | # MySQL engine shim; orchestration lives in db-harness-lib. | COMMENT |
| 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 |
| MEDIUM | airbyte-integrations/db-harness-lib/scripts/run.sh | 2 | # One-shot entrypoint for a database connector e2e harness. | COMMENT |
| MEDIUM | airbyte-integrations/db-harness-lib/scripts/run.sh | 268 | # The harness pulls published control tags itself but cannot build :dev. | 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/hydra-automerge.yml | 88 | # Never auto-merge PRs created by the airbytehq/ai-skills eval harness, | COMMENT |
| MEDIUM⚡ | .github/workflows/autodoc.yml | 38 | fetch-depth: 0 # Full history needed for comprehensive analysis | CODE |
| 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 | …gres/.agents/skills/source-postgres-e2e-tests/SKILL.md | 49 | │ └── run.sh # engine shim to db-harness-lib orchestration | CODE |
| MEDIUM | …agents/skills/source-postgres-e2e-tests/scripts/run.sh | 2 | # PostgreSQL engine shim; orchestration lives in db-harness-lib. | COMMENT |
| MEDIUM | …gents/skills/source-snowflake-e2e-tests/scripts/run.sh | 2 | # Snowflake engine shim; orchestration lives in db-harness-lib. | COMMENT |
| MEDIUM | …e-mssql/.agents/skills/source-mssql-e2e-tests/SKILL.md | 49 | │ └── run.sh # engine shim to db-harness-lib orchestration | CODE |
| MEDIUM | …l/.agents/skills/source-mssql-e2e-tests/scripts/run.sh | 2 | # MSSQL engine shim; orchestration lives in db-harness-lib. | COMMENT |
| MEDIUM | …v2/.agents/skills/source-mongodb-v2-e2e-tests/SKILL.md | 49 | │ └── run.sh # engine shim to db-harness-lib orchestration | CODE |
| MEDIUM | …ents/skills/source-mongodb-v2-e2e-tests/scripts/run.sh | 2 | # MongoDB engine shim; orchestration lives in db-harness-lib. | COMMENT |
| MEDIUM | …e-mysql/.agents/skills/source-mysql-e2e-tests/SKILL.md | 46 | │ └── run.sh # engine shim to db-harness-lib orchestration | CODE |
| MEDIUM | …l/.agents/skills/source-mysql-e2e-tests/scripts/run.sh | 2 | # MySQL engine shim; orchestration lives in db-harness-lib. | COMMENT |
| MEDIUM | airbyte-integrations/db-harness-lib/README.md | 95 | # PostgreSQL engine shim; orchestration lives in db-harness-lib. | COMMENT |
| 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/integrations/destinations/snowflake.md | 576 | | 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 | 475 | | 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 | 478 | | 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 | 485 | | 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 | 487 | | 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 |
|---|---|---|---|---|
| LOW⚡ | …ectors/source-google-ads/unit_tests/test_components.py | 1133 | # Step 1: Serialize MESSAGE fields | COMMENT |
| LOW⚡ | …ectors/source-google-ads/unit_tests/test_components.py | 1141 | # 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 | 102 | // Step 1: Finalize the gzip CSV | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 117 | // Step 2: Upload to S3 | COMMENT |
| LOW⚡ | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 120 | // Step 3: Execute COPY | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 131 | // Step 4: Cleanup S3 staging file | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 143 | // Step 5: Reset state | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 220 | // Step 1: Resolve extended placeholders ({date:<format>}, {timestamp:millis|micro}) | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 242 | // Step 2: Resolve standard placeholders | COMMENT |
| LOW | …estination/redshift/write/load/RedshiftInsertBuffer.kt | 253 | // Step 3: Ensure the file has the correct extension for Redshift COPY | COMMENT |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 233 | // Step 1: Materialize deduped rows into a session-scoped temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 236 | // Step 2: CDC hard-delete (if enabled) | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 255 | // Step 3: Update existing rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 258 | // Step 4: Insert new rows | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 261 | // Step 5: Drop temp table | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 487 | // Step 1: Add temp column with the new type | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 489 | // Step 2: Cast data from old column to temp column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 491 | // Step 3: Record DESTINATION_TYPECAST_ERROR in _airbyte_meta for rows where | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 502 | // Step 4: Drop the original column | STRING |
| LOW⚡ | …tions/destination/redshift/sql/RedshiftSqlGenerator.kt | 504 | // 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 |
|---|---|---|---|---|
| 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 | 121 | | 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 | 4784 | # 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 | 207 | CODE | |
| LOW | …rce-shopify/unit_tests/integration/test_bulk_stream.py | 482 | CODE | |
| LOW | …rce-shopify/unit_tests/integration/test_bulk_stream.py | 487 | CODE | |
| LOW | …source-google-directory/source_google_directory/api.py | 75 | CODE | |
| LOW | …ions/connectors/source-youtube-analytics/components.py | 81 | CODE | |
| LOW | …/connectors/source-mixpanel/source_mixpanel/streams.py | 71 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 639 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 979 | CODE | |
| LOW | …/connectors/source-amazon-seller-partner/components.py | 1193 | 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 | 78 | 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 | tools/bin/bulk-cdk/auto-upgrade/build-slack-summary.sh | 14 | # Usage: | COMMENT |
| LOW | airbyte-integrations/db-harness-lib/scripts/run.sh | 18 | # 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 |
| LOW | .github/scripts/docs-changelog-only.sh | 12 | # Usage: | COMMENT |
| Severity | File | Line | Snippet | Context |
|---|---|---|---|---|
| MEDIUM | …ectors/source-google-ads/unit_tests/test_components.py | 592 | CODE | |
| MEDIUM | …ectors/source-google-ads/unit_tests/test_components.py | 663 | CODE | |
| MEDIUM | …ectors/source-google-ads/unit_tests/test_components.py | 691 | CODE | |
| MEDIUM | …ectors/source-google-ads/unit_tests/test_components.py | 852 | CODE | |
| MEDIUM | …/unit_tests/mock_server/test_chunked_encoding_error.py | 283 | CODE |
| 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 |
|---|---|---|---|---|
| LOW | …/source/postgres/PostgresSourceJdbcPartitionFactory.kt | 499 | // TODO: implement split for cursor incremental partition | COMMENT |