Repository Analysis

airbytehq/airbyte

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.

4.4 Likely human-written View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of airbytehq/airbyte, a Python project with 21,622 GitHub stars. SynthScan v2.0 examined 3,573,533 lines of code across 14361 source files, recording 8437 pattern matches distributed across 27 syntactic categories. The overall adjusted score of 4.4 places this repository in the Likely human-written band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

4.4
Adjusted Score
4.4
Raw Score
100%
Time Factor
2026-07-14
Last Push
21.6K
Stars
Python
Language
3.6M
Lines of Code
14.4K
Files
8.4K
Pattern Hits
2026-07-14
Scan Date
0.10
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 182HIGH 1201MEDIUM 209LOW 6845

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 8437 distinct pattern matches across 27 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Cross-File Repetition1103 hits · 5515 pts
SeverityFileLineSnippetContext
HIGH…nnectors/source-strava/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-appsflyer/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…tors/source-babelforce/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…e-rd-station-marketing/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…connectors/source-zoom/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…connectors/source-cart/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…nnectors/source-timely/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…source-tvmaze-schedule/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…tors/source-mailerlite/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…onnectors/source-wrike/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…/connectors/source-rss/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…rce-azure-blob-storage/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…s/source-commercetools/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-gutendex/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-iterable/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-news-api/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…rs/source-youtube-data/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ors/source-bigcommerce/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…nectors/source-shopify/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…/source-survey-sparrow/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…tors/source-greenhouse/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-teradata/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ource-tiktok-marketing/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…rs/source-zendesk-chat/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…onnectors/source-pendo/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…/source-aws-cloudtrail/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…connectors/source-okta/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-insightly/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-recruitee/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-persistiq/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ors/source-freshcaller/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-couchbase/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…/source-facebook-pages/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-lokalise/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…pier-supported-storage/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…connectors/source-jira/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ource-outbrain-amplify/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…source-coingecko-coins/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…s/source-google-sheets/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-dockerhub/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-us-census/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…tors/source-senseforce/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ors/source-azure-table/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…rce-scaffold-java-jdbc/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…connectors/source-tidb/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-qualaroo/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ce-yahoo-finance-price/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…onnectors/source-faker/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…connectors/source-tmdb/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ctors/source-waiteraid/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…tors/source-tplcentral/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-omnisend/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…tors/source-clickhouse/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…rs/source-freshservice/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…nectors/source-zenloop/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…nnectors/source-oracle/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…connectors/source-oura/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…ectors/source-commcare/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…nectors/source-klaviyo/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
HIGH…/destination-sftp-json/integration_tests/acceptance.py0this fixture is a placeholder for external resources that acceptance test might require.STRING
1043 more matches not shown…
Hyper-Verbose Identifiers4074 hits · 4184 pts
SeverityFileLineSnippetContext
LOW…connectors/source-appsflyer/source_appsflyer/source.py80 def is_aggregate_reports_reached_limit(self, response: requests.Response) -> bool:CODE
LOW…connectors/source-appsflyer/source_appsflyer/source.py87 def is_raw_data_reports_reached_limit(self, response: requests.Response) -> bool:CODE
LOW…connectors/source-appsflyer/source_appsflyer/source.py394 def is_start_date_before_earliest_date(self, start_date, earliest_date):CODE
LOW…connectors/source-appsflyer/unit_tests/test_streams.py113def test_backoff_time_retry_after_header(patch_base_class):CODE
LOW…connectors/source-appsflyer/unit_tests/test_streams.py146def test_transform_function_no_decimal(patch_base_class, original_value, field_schema, expected):CODE
LOW…ource-appsflyer/unit_tests/test_incremental_streams.py28def patch_incremental_base_class(mocker):CODE
LOW…ource-appsflyer/unit_tests/test_incremental_streams.py128def 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.py158def test_supports_incremental(patch_incremental_base_class, mocker):CODE
LOW…ource-appsflyer/unit_tests/test_incremental_streams.py165def test_source_defined_cursor(patch_incremental_base_class, mocker):CODE
LOW…ource-appsflyer/unit_tests/test_incremental_streams.py171def test_stream_checkpoint_interval(patch_incremental_base_class, mocker):CODE
LOW…egrations/connectors/source-linkedin-ads/components.py165def transform_change_audit_stamps(CODE
LOW…egrations/connectors/source-linkedin-ads/components.py252def transform_targeting_criteria(record: Dict, dict_key: str = "targetingCriteria") -> Mapping[str, Any]:CODE
LOW…nectors/source-linkedin-ads/unit_tests/test_streams.py33def test_analytics_stream_slices(requests_mock):CODE
LOW…tors/source-linkedin-ads/unit_tests/test_components.py33def mock_analytics_cursor_params():CODE
LOW…tors/source-linkedin-ads/unit_tests/test_components.py48def test_safe_http_client_create_prepared_request(components_module):CODE
LOW…tors/source-linkedin-ads/unit_tests/test_components.py67def test_safe_encode_http_requester_post_init(components_module):CODE
LOW…tors/source-linkedin-ads/unit_tests/test_components.py85def test_linkedin_ads_record_extractor_extract_records(components_module, mock_response):CODE
LOW…tors/source-linkedin-ads/unit_tests/test_components.py102def test_date_str_from_date_range(components_module):CODE
LOW…tors/source-linkedin-ads/unit_tests/test_components.py115def test_linkedin_ads_error_handler_invalid_url(components_module):CODE
LOW…tors/source-linkedin-ads/unit_tests/test_components.py134def test_linkedin_ads_error_handler_http_response(components_module):CODE
LOW…/connectors/source-linkedin-ads/unit_tests/conftest.py23def clear_cache_before_each_test():CODE
LOW…nnectors/source-linkedin-ads/unit_tests/test_source.py69 def _mock_initialize_cache_for_parent_streams(stream_configs: List[Dict[str, Any]]) -> List[Dict[str, Any]]:CODE
LOW…nnectors/source-linkedin-ads/unit_tests/test_source.py72 def update_with_cache_parent_configs(parent_configs: list[dict[str, Any]]) -> None:CODE
LOW…nnectors/source-linkedin-ads/unit_tests/test_source.py99 def test_should_retry_on_error(self, error_code, requests_mock, mocker):CODE
LOW…nnectors/source-linkedin-ads/unit_tests/test_source.py277 def test_ad_campaign_analytics_stream(self, requests_mock):CODE
LOW…ests/mock_server/test_ad_member_job_title_analytics.py93 def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_job_title_analytics.py120 def test_transformations_applied(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_job_title_analytics.py152 def test_incremental_sync_initial(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_job_title_analytics.py201 def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_job_title_analytics.py228 def test_analytics_data_fields(self, http_mocker: HttpMocker):CODE
LOW…inkedin-ads/unit_tests/mock_server/test_conversions.py44def _create_conversion_record(CODE
LOW…inkedin-ads/unit_tests/mock_server/test_conversions.py74 def test_full_refresh_with_multiple_parent_accounts(self, http_mocker: HttpMocker):CODE
LOW…inkedin-ads/unit_tests/mock_server/test_conversions.py161 def test_incremental_sync_initial(self, http_mocker: HttpMocker):CODE
LOW…inkedin-ads/unit_tests/mock_server/test_conversions.py190 def test_incremental_sync_with_state(self, http_mocker: HttpMocker):CODE
LOW…inkedin-ads/unit_tests/mock_server/test_conversions.py256 def test_parent_with_no_child_records(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_seniority_analytics.py93 def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_seniority_analytics.py120 def test_transformations_applied(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_seniority_analytics.py152 def test_incremental_sync_initial(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_seniority_analytics.py201 def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker):CODE
LOW…ests/mock_server/test_ad_member_seniority_analytics.py228 def test_analytics_data_fields(self, http_mocker: HttpMocker):CODE
LOW…s/mock_server/test_ad_member_company_size_analytics.py96 def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker):CODE
LOW…s/mock_server/test_ad_member_company_size_analytics.py123 def test_transformations_applied(self, http_mocker: HttpMocker):CODE
LOW…s/mock_server/test_ad_member_company_size_analytics.py155 def test_incremental_sync_initial(self, http_mocker: HttpMocker):CODE
LOW…s/mock_server/test_ad_member_company_size_analytics.py204 def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker):CODE
LOW…s/mock_server/test_ad_member_company_size_analytics.py231 def test_analytics_data_fields(self, http_mocker: HttpMocker):CODE
LOW…s/source-linkedin-ads/unit_tests/mock_server/config.py51 def with_ad_analytics_reports(self, reports: List[Dict[str, Any]]) -> "ConfigBuilder":CODE
LOW…_tests/mock_server/test_ad_member_company_analytics.py93 def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker):CODE
LOW…_tests/mock_server/test_ad_member_company_analytics.py120 def test_transformations_applied(self, http_mocker: HttpMocker):CODE
LOW…_tests/mock_server/test_ad_member_company_analytics.py152 def test_incremental_sync_initial(self, http_mocker: HttpMocker):CODE
LOW…_tests/mock_server/test_ad_member_company_analytics.py201 def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker):CODE
LOW…_tests/mock_server/test_ad_member_company_analytics.py228 def test_analytics_data_fields(self, http_mocker: HttpMocker):CODE
LOW…unit_tests/mock_server/test_custom_analytics_report.py91def _get_custom_analytics_report_config() -> list:CODE
LOW…unit_tests/mock_server/test_custom_analytics_report.py130 def test_full_refresh_with_single_parent_campaign(self, http_mocker: HttpMocker):CODE
LOW…unit_tests/mock_server/test_custom_analytics_report.py164 def test_transformations_applied(self, http_mocker: HttpMocker):CODE
LOW…unit_tests/mock_server/test_custom_analytics_report.py210 def test_incremental_sync_initial(self, http_mocker: HttpMocker):CODE
LOW…unit_tests/mock_server/test_custom_analytics_report.py271 def test_parent_with_no_analytics_data(self, http_mocker: HttpMocker):CODE
LOW…unit_tests/mock_server/test_custom_analytics_report.py304 def test_analytics_data_fields(self, http_mocker: HttpMocker):CODE
LOW…unit_tests/mock_server/test_custom_analytics_report.py342 def test_multiple_parent_campaigns(self, http_mocker: HttpMocker):CODE
LOW…-linkedin-ads/unit_tests/mock_server/test_creatives.py71 def test_full_refresh_with_multiple_parent_accounts(self, http_mocker: HttpMocker):CODE
LOW…-linkedin-ads/unit_tests/mock_server/test_creatives.py161 def test_incremental_sync_initial(self, http_mocker: HttpMocker):CODE
4014 more matches not shown…
Hallucination Indicators182 hits · 1780 pts
SeverityFileLineSnippetContext
CRITICAL…ry/write/bulk_loader/ProtoToBigQueryCSVRowGenerator.kt567 return com.google.cloud.bigquery.QueryParameterValue.timestamp(emittedAtMicroseconds)CODE
CRITICAL…lob-storage/source_azure_blob_storage/stream_reader.py10from azure.core.exceptions import ResourceNotFoundErrorCODE
CRITICAL…ns/destination/clickhouse/ClickhouseContainerHelper.kt38 return container.containerInfo.networkSettings.networks.entries.first().value.ipAddressCODE
CRITICAL…tions/destination/gcs_data_lake/GcsPolarisWriteTest.kt36 io.airbyte.cdk.load.data.icerberg.parquet.IcebergDataDumper(CODE
CRITICAL…_tests/sources/ClickHouseJdbcSourceAcceptanceTest.java139 return Jsons.jsonNode(com.google.common.collect.ImmutableMap.of(CODE
CRITICAL…ors/source-instagram/integration_tests/test_streams.py58 len(state_msg.state.stream.stream_state.__dict__.get("states", {})),CODE
CRITICAL…ns/connectors/source-gitlab/unit_tests/test_streams.py179 assert commits._stream_partition_generator._partition_factory._retriever.requester.get_request_params() == {"with_stCODE
CRITICAL…grations/destination/oracle/OracleDestinationTest.java132 return Jsons.jsonNode(com.google.common.collect.ImmutableMap.of(CODE
CRITICAL…egrations/destination/mssql/v2/MSSQLContainerHelper.kt46 return testContainer.containerInfo.networkSettings.networks.entries.first().value.ipAddressCODE
CRITICAL…ination/singlestore/SingleStoreTypingDedupingTest.java75 return io.airbyte.commons.json.Jsons.jsonNode(ImmutableMap.builder()CODE
CRITICAL…ination/singlestore/SingleStoreTypingDedupingTest.java137 new io.airbyte.protocol.models.v0.ConfiguredAirbyteCatalog()CODE
CRITICAL…inglestore/SingleStoreSqlGeneratorIntegrationTest.java204 .withJsonSchema(io.airbyte.protocol.models.Jsons.jsonNode(Map.of("type", "object", "properties",CODE
CRITICAL…inglestore/SingleStoreSqlGeneratorIntegrationTest.java218 List.of(io.airbyte.protocol.models.Jsons.jsonNode(Map.of("_airbyte_raw_id", "ad3e8c84-e02e-4df4-b146-3d5a007b2CODE
CRITICAL…egrations/source/mssql/MsSqlServerDebeziumConverter.kt280 com.microsoft.sqlserver.jdbc.Geography.deserialize(bytes).toString()CODE
CRITICAL…egrations/source/mssql/MsSqlServerDebeziumConverter.kt283 com.microsoft.sqlserver.jdbc.Geometry.deserialize(bytes).toString()CODE
CRITICAL…integrations/source/singlestore/SingleStoreSource.java97 + com.singlestore.jdbc.export.SslMode.from(entry.getValue()).name();CODE
CRITICAL…grations/source/singlestore/SingleStoreQueryUtils.java89 new io.airbyte.protocol.models.v0.AirbyteStreamNameNamespacePair(name, namespace));STRING
CRITICAL…grations/source/singlestore/SingleStoreQueryUtils.java111 cursorBasedStatusMap.put(new io.airbyte.protocol.models.v0.AirbyteStreamNameNamespacePair(name, namespace), cursSTRING
CRITICAL…ons/source/mongodb/cdc/MongoDbCdcStateHandlerTest.java27 final MongoDbSourceConfig CONFIG = new MongoDbSourceConfig(io.airbyte.commons.json.Jsons.jsonNode(CODE
CRITICAL…b-v2/src/test/debezium/DebeziumMongoDbConnectorTest.kt114 .using(io.debezium.engine.spi.OffsetCommitPolicy.AlwaysCommitOffsetPolicy())CODE
CRITICAL…b-v2/src/test/debezium/DebeziumMongoDbConnectorTest.kt171 .using(io.debezium.engine.spi.OffsetCommitPolicy.AlwaysCommitOffsetPolicy())CODE
CRITICAL…ations/destination/snowflake/check/SnowflakeChecker.kt80 io.airbyte.cdk.load.component.ColumnType("VARCHAR", false)CODE
CRITICAL…component/config/SnowflakeTestTableOperationsClient.kt56 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…connectors/source-pinterest/unit_tests/test_streams.py75 result = stream._stream_partition_generator._partition_factory._retriever.requester.get_path(CODE
CRITICAL…ns/destination/postgres/write/PostgresRawDataDumper.kt397 io.airbyte.cdk.load.data.IntegerValue(CODE
CRITICAL…ns/destination/postgres/write/PostgresRawDataDumper.kt401 io.airbyte.cdk.load.data.NumberValue(CODE
CRITICAL…ns/destination/postgres/write/PostgresRawDataDumper.kt407 io.airbyte.cdk.load.data.BooleanValue(CODE
CRITICAL…grations/connectors/source-hubspot/unit_tests/utils.py15 stream_instance._stream_partition_generator._partition_factory._retriever.record_selector._transform(record,CODE
CRITICAL…ons/connectors/source-github/unit_tests/test_stream.py1559 stream._parent_stream._http_client._session.cache.clear()CODE
CRITICAL…ons/connectors/source-github/unit_tests/test_stream.py1620 stream._parent_stream._http_client._session.cache.clear()CODE
CRITICAL…tors/source-github/source_github/backoff_strategies.py42 self.stream._http_client._session.auth.update_token() # New token will be used in next requestCODE
CRITICAL…/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt57 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
CRITICAL…/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt59 io.airbyte.cdk.load.schema.model.TableNames(CODE
CRITICAL…/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt61 io.airbyte.cdk.load.schema.model.TableName(CODE
CRITICAL…/io/airbyte/cdk/load/dataflow/stages/ParseStageTest.kt67 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…taflow/state/stats/socket/EmittedStatsStoreImplTest.kt241 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
CRITICAL…taflow/state/stats/socket/EmittedStatsStoreImplTest.kt243 io.airbyte.cdk.load.schema.model.TableNames(CODE
CRITICAL…taflow/state/stats/socket/EmittedStatsStoreImplTest.kt245 io.airbyte.cdk.load.schema.model.TableName(CODE
CRITICAL…taflow/state/stats/socket/EmittedStatsStoreImplTest.kt251 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt68 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt70 io.airbyte.cdk.load.schema.model.TableNames(CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt72 io.airbyte.cdk.load.schema.model.TableName(CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt78 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt500 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt502 io.airbyte.cdk.load.schema.model.TableNames(CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt504 io.airbyte.cdk.load.schema.model.TableName("namespace", "name")CODE
CRITICAL…/io/airbyte/cdk/load/message/DestinationMessageTest.kt507 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt52 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt54 io.airbyte.cdk.load.schema.model.TableNames(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt56 io.airbyte.cdk.load.schema.model.TableName(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt62 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt297 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt299 io.airbyte.cdk.load.schema.model.TableNames(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt301 io.airbyte.cdk.load.schema.model.TableName(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt307 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt393 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt395 io.airbyte.cdk.load.schema.model.TableNames(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt397 io.airbyte.cdk.load.schema.model.TableName(CODE
CRITICAL…o/airbyte/cdk/load/message/DestinationRecordRawTest.kt403 io.airbyte.cdk.load.schema.model.ColumnSchema(CODE
CRITICAL…load/data/EnrichedDestinationRecordAirbyteValueTest.kt29 io.airbyte.cdk.load.schema.model.StreamTableSchema(CODE
122 more matches not shown…
Structural Annotation Overuse533 hits · 841 pts
SeverityFileLineSnippetContext
LOW…-lake/src/test-integration/resources/polaris/README.md20### Step 1: Update Service Account Credentials FileCOMMENT
LOW…-lake/src/test-integration/resources/polaris/README.md29### Step 2: Update PolarisEnvironment ConfigurationCOMMENT
LOW…-lake/src/test-integration/resources/polaris/README.md50### Step 3: Run the TestsCOMMENT
LOW…/test-integration/resources/polaris/docker-compose.yml1# WARNING: This docker-compose.gcs.yml file is tightly coupled with PolarisEnvironment.kt.COMMENT
LOW…ectors/source-google-ads/unit_tests/test_components.py990 # Step 1: Serialize MESSAGE fieldsCOMMENT
LOW…ectors/source-google-ads/unit_tests/test_components.py998 # Step 2: Flatten nested dictsCOMMENT
LOW…ource-sendgrid/unit_tests/mock_server/test_contacts.py38 # Step 1: Mock the export creation request (POST)COMMENT
LOW…ource-sendgrid/unit_tests/mock_server/test_contacts.py49 # Step 2: Mock the polling request (GET status) - return "ready" statusCOMMENT
LOW…ource-sendgrid/unit_tests/mock_server/test_contacts.py67 # Step 3: Mock the download request - return plain CSV with uppercase field namesCOMMENT
LOW…ortex/destination_snowflake_cortex/cortex_processor.py223 # WARNING: This is untested and may not work as expected.COMMENT
LOW…urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java102 // Step 1: Convert underscores to dashes (matches Debezium's normalizeName behavior)COMMENT
LOW…urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java105 // Step 2: Replace special characters with underscoresCOMMENT
LOW…/test-integration/resources/polaris/docker-compose.yml1# WARNING: This docker-compose.yml file is tightly coupled with PolarisEnvironment.kt.COMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt376 // Step 1: Create principal and retrieve OAuth credentials (clientId and clientSecret)COMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt401 // Step 2: Create principal role (realm-wide) and catalog role (catalog-specific)COMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt405 // Step 3: Link catalog role to principal role for the specific catalogCOMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt418 // Step 4: Grant required privileges to the catalog roleCOMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt424 // Step 5: Attach the principal role to the principal (completes the permission chain)COMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt101 // Step 1: Finalize the gzip CSVCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt116 // Step 2: Upload to S3COMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt119 // Step 3: Execute COPYCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt130 // Step 4: Cleanup S3 staging fileCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt142 // Step 5: Reset stateCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt219 // Step 1: Resolve extended placeholders ({date:<format>}, {timestamp:millis|micro})COMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt241 // Step 2: Resolve standard placeholdersCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt252 // Step 3: Ensure the file has the correct extension for Redshift COPYCOMMENT
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt229 // Step 1: Materialize deduped rows into a session-scoped temp tableSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt232 // Step 2: CDC hard-delete (if enabled)STRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt251 // Step 3: Update existing rowsSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt254 // Step 4: Insert new rowsSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt257 // Step 5: Drop temp tableSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt482 // Step 1: Add temp column with the new typeSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt484 // Step 2: Cast data from old column to temp columnSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt486 // Step 3: Record DESTINATION_TYPECAST_ERROR in _airbyte_meta for rows whereSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt497 // Step 4: Drop the original columnSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt499 // Step 5: Rename temp column to the original nameSTRING
LOW…nectors/source-sftp-bulk/integration_tests/conftest.py52 # Step 1: Extract the base CSV file from the ZIP archiveCOMMENT
LOW…nectors/source-sftp-bulk/integration_tests/conftest.py65 # Step 2: Create duplicates with different namesCOMMENT
LOWdocs/ai-agents/slack-app.md61### Step 1: Sign in to Airbyte AgentsCOMMENT
LOWdocs/ai-agents/slack-app.md67### Step 2: Add the Slack connectorCOMMENT
LOWdocs/ai-agents/slack-app.md73### Step 3: Authenticate with SlackCOMMENT
LOWdocs/ai-agents/slack-app.md83### Step 4: Save and verifyCOMMENT
LOWdocs/ai-agents/slack-app.md89### Step 5: Start using the connectorCOMMENT
LOWdocs/ai-agents/admin/sso.md22### Step 1: Create an SSO configurationCOMMENT
LOWdocs/ai-agents/admin/sso.md42### Step 2: Verify your domainCOMMENT
LOWdocs/ai-agents/admin/sso.md63### Step 3: Activate SSOCOMMENT
LOW…agents/interfaces/api/authentication/build-your-own.md348// Step 1: Initiate OAuth when user clicks "Connect HubSpot"COMMENT
LOW…agents/interfaces/api/authentication/build-your-own.md378// Step 2: Handle OAuth callback - connector is already createdCOMMENT
LOW…agents/interfaces/api/authentication/build-your-own.md393// Step 3: Execute operations using the connectorCOMMENT
LOWdocs/platform/using-airbyte/configuring-api-access.md28## Step 1: Create an applicationCOMMENT
LOWdocs/platform/using-airbyte/configuring-api-access.md80## Step 2: Get an access tokenCOMMENT
LOWdocs/platform/using-airbyte/configuring-api-access.md167## Step 3: Use your access tokenCOMMENT
LOW…r-development/connector-builder-ui/stream-templates.md67### Step 1: Create a new connector in the Connector BuilderCOMMENT
LOW…r-development/connector-builder-ui/stream-templates.md79### Step 2: Create a new Stream TemplateCOMMENT
LOW…r-development/connector-builder-ui/stream-templates.md89### Step 3: Configure Generated Stream TemplateCOMMENT
LOW…r-development/connector-builder-ui/stream-templates.md109### Step 4: Generate streamsCOMMENT
LOW…r-development/tutorials/building-a-java-destination.md49### Step 1: Create the destinationCOMMENT
LOW…r-development/tutorials/building-a-java-destination.md53### Step 2: Build the newly generated destinationCOMMENT
LOW…r-development/tutorials/building-a-java-destination.md178### Step 3: Implement `spec`COMMENT
LOW…r-development/tutorials/building-a-java-destination.md204### Step 4: Implement `check`COMMENT
473 more matches not shown…
Unused Imports672 hits · 661 pts
SeverityFileLineSnippetContext
LOWtools/bin/identify-dormant-workflows.py6CODE
LOWtools/schema_generator/tests/test_schema_generator.py11CODE
LOWtools/schema_generator/tests/test_schema_generator.py12CODE
LOWtools/schema_generator/tests/test_schema_generator.py12CODE
LOWtools/schema_generator/tests/test_schema_generator.py12CODE
LOWtools/schema_generator/tests/test_schema_generator.py12CODE
LOWtools/schema_generator/tests/test_schema_generator.py12CODE
LOWtools/schema_generator/tests/test_schema_generator.py12CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOWtools/schema_generator/tests/tests.py5CODE
LOW…ols/schema_generator/schema_generator/infer_schemas.py29CODE
LOW…nnectors/source-appsflyer/source_appsflyer/__init__.py6CODE
LOW…connectors/source-appsflyer/source_appsflyer/source.py22CODE
LOW…s/source-appsflyer/source_appsflyer/fields/__init__.py1CODE
LOW…s/source-appsflyer/source_appsflyer/fields/__init__.py1CODE
LOW…ource-appsflyer/unit_tests/test_incremental_streams.py8CODE
LOW…rations/connectors/source-cart/source_cart/__init__.py25CODE
LOW…rations/connectors/source-cart/source_cart/__init__.py25CODE
LOW…rations/connectors/source-cart/source_cart/__init__.py25CODE
LOW…egrations/connectors/source-linkedin-ads/components.py24CODE
LOW…egrations/connectors/source-linkedin-ads/components.py24CODE
LOW…s/source-linkedin-ads/unit_tests/mock_server/config.py3CODE
LOW…s/source-linkedin-ads/unit_tests/mock_server/config.py4CODE
LOW…linkedin-ads/unit_tests/mock_server/request_builder.py3CODE
LOW…s/unit_tests/mock_server/test_ad_campaign_analytics.py11CODE
LOW…s/unit_tests/mock_server/test_ad_campaign_analytics.py12CODE
LOW…kedin-ads/unit_tests/mock_server/test_account_users.py3CODE
LOW…kedin-ads/unit_tests/mock_server/test_account_users.py12CODE
LOW…-linkedin-ads/unit_tests/mock_server/test_campaigns.py3CODE
LOW…-linkedin-ads/unit_tests/mock_server/test_campaigns.py12CODE
LOW…egrations/connectors/source-rss/source_rss/__init__.py6CODE
LOW…ctors/source-azure-blob-storage/build_customization.py4CODE
LOW…ure-blob-storage/source_azure_blob_storage/__init__.py6CODE
LOW…ure-blob-storage/source_azure_blob_storage/__init__.py7CODE
LOW…ure-blob-storage/source_azure_blob_storage/__init__.py8CODE
LOW…/source-commercetools/source_commercetools/__init__.py6CODE
LOW…ource-commercetools/source_commercetools/components.py6CODE
LOW…/destination-rabbitmq/destination_rabbitmq/__init__.py6CODE
LOW…nnectors/destination-kvdb/destination_kvdb/__init__.py24CODE
LOW…/connectors/source-iterable/source_iterable/streams.py18CODE
LOW…connectors/source-iterable/source_iterable/__init__.py1CODE
LOW…connectors/source-shopify/unit_tests/test_transform.py5CODE
LOW…rce-shopify/unit_tests/integration/test_bulk_stream.py7CODE
LOW…s/connectors/source-shopify/source_shopify/__init__.py25CODE
LOW…e-shopify/source_shopify/shopify_graphql/bulk/query.py14CODE
LOW…ctors/source-shopify/source_shopify/streams/streams.py6CODE
LOW…ctors/source-shopify/source_shopify/streams/streams.py42CODE
LOW…tors/destination-chroma/destination_chroma/__init__.py6CODE
LOW…tors/source-tiktok-marketing/unit_tests/test_source.py5CODE
LOW…ce-tiktok-marketing/unit_tests/integration/__init__.py3CODE
LOW…/source-zendesk-chat/unit_tests/pagination_strategy.py3CODE
LOW…zendesk-chat/unit_tests/mock_server/request_builder.py3CODE
LOW…e-zendesk-chat/unit_tests/mock_server/test_accounts.py12CODE
LOW…tination-amazon-sqs/destination_amazon_sqs/__init__.py6CODE
612 more matches not shown…
Over-Commented Block594 hits · 559 pts
SeverityFileLineSnippetContext
LOWruff.toml21# "ASYNC", # flake8-asyncCOMMENT
LOWruff.toml41# "INP", # flake8-no-pep420COMMENT
LOWruff.toml61# "SLOT", # flake8-slotsCOMMENT
LOWtools/bin/bulk-cdk/get-certified-connectors.sh1#!/usr/bin/env bashCOMMENT
LOWtools/bin/bulk-cdk/get-certified-connectors.sh81# Nonobvious `printf | jq | jq` thing here:COMMENT
LOWtools/bin/cdk-auto-release/update-changelog.sh1#!/bin/bashCOMMENT
LOW…ols/bin/bulk-cdk-compatibility-test/create-gh-issue.sh1#!/usr/bin/env bashCOMMENT
LOW…ols/schema_generator/schema_generator/infer_schemas.py1#COMMENT
LOW…connectors/source-strava/integration_tests/__init__.py1#COMMENT
LOW…ons/connectors/source-appsflyer/unit_tests/__init__.py1#COMMENT
LOW…ectors/source-babelforce/integration_tests/__init__.py1#COMMENT
LOW…rce-rd-station-marketing/integration_tests/__init__.py1#COMMENT
LOW…s/connectors/source-zoom/integration_tests/__init__.py1#COMMENT
LOW…egrations/connectors/source-linkedin-ads/manifest.yaml1661# https://learn.microsoft.com/en-us/linkedin/shared/api-guide/concepts/rate-limitsCOMMENT
LOW…connectors/source-timely/integration_tests/__init__.py1#COMMENT
LOW…/connectors/source-stock-ticker-api-tutorial/source.py1# MIT LicenseCOMMENT
LOW…s/source-tvmaze-schedule/integration_tests/__init__.py1#COMMENT
LOW…ectors/source-mailerlite/integration_tests/__init__.py1#COMMENT
LOW…/connectors/source-wrike/integration_tests/__init__.py1#COMMENT
LOW…tination/bigquery/formatter/BigQueryRecordFormatter.kt261 value.nullify(Reason.DESTINATION_FIELD_SIZE_LIMITATION)COMMENT
LOW…integrations/destination/bigquery/BigQueryCheckTest.kt21 CheckTestConfig(COMMENT
LOWairbyte-integrations/connectors/source-rss/__init__.py1#COMMENT
LOW…ns/connectors/source-rss/integration_tests/__init__.py1#COMMENT
LOW…ource-azure-blob-storage/integration_tests/__init__.py1#COMMENT
LOW…tegrations/connectors/source-commercetools/__init__.py1#COMMENT
LOW…ors/source-commercetools/integration_tests/__init__.py1#COMMENT
LOW…nnectors/destination-kvdb/destination_kvdb/__init__.py1# MIT LicenseCOMMENT
LOW…nnectors/source-gutendex/integration_tests/__init__.py1#COMMENT
LOW…nnectors/source-news-api/integration_tests/__init__.py1#COMMENT
LOW…tors/source-youtube-data/integration_tests/__init__.py1#COMMENT
LOW…ctors/source-bigcommerce/integration_tests/__init__.py1#COMMENT
LOW…rs/source-survey-sparrow/integration_tests/__init__.py1#COMMENT
LOW…ectors/source-greenhouse/integration_tests/__init__.py1#COMMENT
LOW…/clickhouse/component/ClickhouseTableOperationsTest.kt61 // clickhouse doesn't have an explicit upsert table - we're relying on clickhouse's table engineCOMMENT
LOW…ons/connectors/source-pendo/acceptance-test-config.yml21 empty_streams: []COMMENT
LOW…/connectors/source-pendo/integration_tests/__init__.py1#COMMENT
LOW…ation-amazon-sqs/destination_amazon_sqs/destination.py61 # TODO: Support getting MessageDeduplicationId from a key in the recordCOMMENT
LOW…rs/source-aws-cloudtrail/integration_tests/__init__.py1#COMMENT
LOWairbyte-integrations/connectors/source-okta/__init__.py1#COMMENT
LOW…s/connectors/source-okta/integration_tests/__init__.py1#COMMENT
LOW…nectors/source-insightly/integration_tests/__init__.py1#COMMENT
LOW…connectors/source-recruitee/acceptance-test-config.yml21 empty_streams: []COMMENT
LOW…nectors/source-recruitee/integration_tests/__init__.py1#COMMENT
LOW…rs/source-linkedin-pages/integration_tests/__init__.py1#COMMENT
LOW…connectors/source-persistiq/acceptance-test-config.yml21 empty_streams: []COMMENT
LOW…nectors/source-persistiq/integration_tests/__init__.py1#COMMENT
LOW…integrations/connectors/source-freshcaller/__init__.py1#COMMENT
LOW…ctors/source-freshcaller/integration_tests/__init__.py1#COMMENT
LOW…ons/connectors/source-couchbase/unit_tests/__init__.py1#COMMENT
LOW…nectors/source-couchbase/integration_tests/__init__.py1#COMMENT
LOW…ination/gcs_data_lake/write/GcsDataLakeStreamLoader.kt161 // Instead, we write data using the new schema to the staging branch - that data will beCOMMENT
LOW…nectors/source-appfollow/integration_tests/__init__.py1#COMMENT
LOW…egrations/connectors/source-facebook-pages/__init__.py1#COMMENT
LOW…s/connectors/source-facebook-pages/tools/schema_gen.py181 # },COMMENT
LOW…s/connectors/source-facebook-pages/tools/schema_gen.py201 # "id": {COMMENT
LOW…-integrations/connectors/source-lokalise/metadata.yaml21 documentationUrl: https://docs.airbyte.com/integrations/sources/lokaliseCOMMENT
LOW…nnectors/source-lokalise/integration_tests/__init__.py1#COMMENT
LOW…ce-zapier-supported-storage/acceptance-test-config.yml21 # exact_order: noCOMMENT
LOW…zapier-supported-storage/integration_tests/__init__.py1#COMMENT
LOW…ors/source-outbrain-amplify/acceptance-test-config.yml1# See [Connector Acceptance Tests](https://docs.airbyte.com/connector-development/testing-connectors/connector-acceptancCOMMENT
534 more matches not shown…
Cross-Language Confusion52 hits · 310 pts
SeverityFileLineSnippetContext
HIGH…ctors/source-azure-blob-storage/build_customization.py18 base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y curl jq"], use_entrypoint=TrueCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py659 return """{"__typename":"FulfillmentOrder","id":"gid:\/\/shopify\/FulfillmentOrder\/2","fulfillAt":"2023-04-24T18:00CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py661{"__typename":"FulfillmentOrderMerchantRequest","id":"gid:\/\/shopify\/FulfillmentOrderMerchantRequest\/333","message":nCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py666 return """{"__typename":"Order","updatedAt":"2023-09-09T09:57:43Z","order_id":"gid:\/\/shopify\/Order\/3944273805501CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py667{"__typename":"Order","updatedAt":"2023-09-19T14:29:22Z","order_id":"gid:\/\/shopify\/Order\/3945528492221","risk":{"recCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py672 return """{"__typename":"Product","id":"gid:\/\/shopify\/Product\/123","publishedAt":"2021-06-23T01:09:29Z","createdCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py687{"__typename":"MediaImage","createdAt":"2024-06-12T23:41:27Z","updatedAt":"2024-06-12T23:41:28Z","image":null,"__parentICODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py692 return """{"__typename":"ProductVariant","id":"gid:\/\/shopify\/ProductVariant\/40091751448765","title":"Metal","priCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py693{"__typename":"ProductVariantPricePair","price":{"amount":"64.0","currencyCode":"USD"},"compareAtPrice":null,"__parentIdCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py694{"__typename":"ProductVariant","id":"gid:\/\/shopify\/ProductVariant\/41561955827901","title":"Test Variant 1","price":"CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py695{"__typename":"ProductVariantPricePair","price":{"amount":"19.0","currencyCode":"USD"},"compareAtPrice":null,"__parentIdCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py700 return """{"__typename":"InventoryItem","id":"gid:\/\/shopify\/InventoryItem\/44871665713341","harmonizedSystemCode"CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py701{"__typename":"InventoryItem","id":"gid:\/\/shopify\/InventoryItem\/45419395743933","harmonizedSystemCode":"330510","proCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py707{"__typename":"Customer","id":"gid:\/\/shopify\/Customer\/456","defaultAddress":{"id":"gid:\/\/shopify\/MailingAddress\/CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py712 return """{"__typename":"Order","order_id":"gid:\/\/shopify\/Order\/4563761987773","createdAt":"2022-06-22T10:50:12ZCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py718{"__typename":"InventoryLevel","id":"gid:\/\/shopify\/InventoryLevel\/97912455357?inventory_item_id=42185200631997","canCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py719{"__typename":"InventoryLevel","id":"gid:\/\/shopify\/InventoryLevel\/97912455357?inventory_item_id=42185218719933","canCODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py724 return """{"__typename":"DiscountCodeNode","id":"gid:\/\/shopify\/DiscountCodeNode\/945205379261","codeDiscount":{"_CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py725{"__typename":"DiscountRedeemCode","usageCount":0,"code":"HZAVNV2487WC","id":"gid:\/\/shopify\/DiscountRedeemCode\/11545CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py726{"__typename":"DiscountRedeemCode","usageCount":0,"code":"SUMMERSALE10OFF","id":"gid:\/\/shopify\/DiscountRedeemCode\/13CODE
HIGH…tions/connectors/source-shopify/unit_tests/conftest.py752 return """{"__typename":"Order","id":"gid:\/\/shopify\/Order\/4554821468349","currency":"USD","transactions":[{"id":CODE
HIGH…tors/source-shopify/unit_tests/integration/api/bulk.py238{{"__typename":"Metafield","id":"gid:\/\/shopify\/Metafield\/{an_id}","namespace":"my_fields","value":"asdfasdf","key":"CODE
HIGH…tors/source-shopify/unit_tests/integration/api/bulk.py256 return f"""{{"__typename":"Customer","id":"gid://shopify/Customer/{a_parent_id}","defaultAddress":{{"id":"gid://STRING
HIGH…ector/destination_pgvector/common/sql/sql_processor.py26from sqlalchemy import Column, Table, and_, create_engine, insert, null, select, text, updateCODE
HIGH…onnectors/destination-sftp-json/build_customization.py18 base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y curl"], use_entrypoint=True)CODE
HIGH…-integrations/connectors/source-bing-ads/components.py339 "Modified Time": null,STRING
HIGH…s/source-bing-ads/unit_tests/integrations/base_test.py75 RequestBuilder(resource="User/Query", api="client_center").with_body('{"UserId": null}').build(),CODE
HIGH…ds/unit_tests/integrations/test_oauth_token_refresh.py22 RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(),CODE
HIGH…ng-ads/unit_tests/integrations/test_accounts_stream.py39 RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(),CODE
HIGH…ng-ads/unit_tests/integrations/test_accounts_stream.py67 RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(),CODE
HIGH…ng-ads/unit_tests/integrations/test_accounts_stream.py103 RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(),CODE
HIGH…ng-ads/unit_tests/integrations/test_accounts_stream.py151 RequestBuilder(resource="User/Query").with_body('{"UserId": null}').build(),CODE
HIGH…/source-firebolt/integration_tests/integration_test.py45 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.py351 q.lambda_("x", q.equals(q.select(["action"], q.var("x")), "remove")),CODE
HIGH…connectors/source-fauna/unit_tests/incremental_test.py284 q.lambda_("x", q.equals(q.select(["action"], q.var("x")), "remove")),CODE
HIGH…connectors/source-fauna/unit_tests/incremental_test.py449 q.lambda_("x", q.equals(q.select(["action"], q.var("x")), "remove")),CODE
HIGH…-salesforce/unit_tests/integration/test_bulk_stream.py288 # default config does not set preserve_na_values -> historical behavior (NA-like strings -> null)COMMENT
HIGH…grations/connectors/source-file/build_customization.py18 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.py64 assert read_file.equals(expected)CODE
HIGH…tions/connectors/source-file/unit_tests/test_client.py86 assert read_file.equals(expected)CODE
HIGH…tions/connectors/source-file/unit_tests/test_client.py100 assert read_file.equals(expected)CODE
HIGH…egrations/connectors/source-gcs/build_customization.py18 base_image_container.with_exec(["sh", "-c", "apt-get update && apt-get install -y curl jq"], use_entrypoint=TrueCODE
HIGH…stination_snowflake_cortex/common/sql/sql_processor.py37 null,CODE
HIGH…ons/connectors/source-marketo/source_marketo/source.py254 Russell,Wilson,null,_mch-localhost-1536605780000-12105STRING
HIGH…connectors/destination-pinecone/build_customization.py17 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.py103 # Netsuite schemas do not specify if fields can be null, or notCOMMENT
HIGH…e-integrations/connectors/source-hubspot/components.py907 {"typeId": 3, "category": "HUBSPOT_DEFINED", "label": null}STRING
HIGH…e-integrations/connectors/source-hubspot/components.py916 {"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.py987 f"listId should be a string to match the schema type [null, string], "CODE
HIGH…s/connectors/source-hubspot/unit_tests/test_streams.py956 schema as [null, string]) can serialize the records without union-resolution failures.STRING
HIGH…s/connectors/source-hubspot/unit_tests/test_streams.py960 then fails Avro union resolution against `[null, string]` at the destination.STRING
HIGH…/source-harvest/unit_tests/mock_server/test_company.py73 # Mock empty response (company returns empty object or null)COMMENT
Excessive Try-Catch Wrapping276 hits · 304 pts
SeverityFileLineSnippetContext
LOW…connectors/source-appsflyer/source_appsflyer/source.py389 except Exception as e:CODE
MEDIUM…connectors/source-appsflyer/source_appsflyer/source.py372def check_connection(self, logger, config) -> Tuple[bool, any]:CODE
LOW…byte-integrations/connectors/source-zoom/components.py86 except Exception as e:CODE
LOW…egrations/connectors/source-cart/source_cart/source.py133 except Exception as e:CODE
LOW…rations/connectors/source-rss/source_rss/components.py51 except Exception:CODE
LOW…rations/connectors/source-rss/source_rss/components.py63 except Exception:CODE
MEDIUM…rations/connectors/source-rss/source_rss/components.py48def is_newer(item, initial_state_date) -> bool:CODE
LOW…ce-azure-blob-storage/source_azure_blob_storage/run.py35 except Exception:CODE
LOW…ource-commercetools/source_commercetools/components.py40 except Exception as e:CODE
LOW…stination-rabbitmq/destination_rabbitmq/destination.py74 except Exception as e:CODE
LOW…stination-rabbitmq/destination_rabbitmq/destination.py82 except Exception as e:CODE
LOW…ctors/destination-kvdb/destination_kvdb/destination.py65 except Exception as e:CODE
LOW…-shopify/source_shopify/shopify_graphql/bulk/record.py371 except Exception as e:CODE
LOW…-shopify/source_shopify/shopify_graphql/bulk/record.py380 except Exception as e:CODE
LOW…ctors/destination-chroma/destination_chroma/indexer.py44 except Exception as e:CODE
LOW…ation-amazon-sqs/destination_amazon_sqs/destination.py173 except Exception as e:CODE
LOW…tions/connectors/source-okta/unit_tests/test_source.py38 except Exception as e:CODE
LOW…tions/connectors/source-okta/unit_tests/test_source.py51 except Exception as e:CODE
LOW…tions/connectors/source-okta/unit_tests/test_source.py83 except Exception as e:CODE
MEDIUM…tions/connectors/source-okta/unit_tests/test_source.py28def test_init_oauth2_authentication_wrong_credentials_record(self, wrong_oauth_cCODE
MEDIUM…tions/connectors/source-okta/unit_tests/test_source.py41def test_init_oauth2_authentication_wrong_oauth_config_bad_auth_type(self, wrongCODE
LOW…tions/connectors/source-okta/source_okta/components.py66 except Exception as e:CODE
LOW…tions/connectors/source-okta/source_okta/components.py118 except Exception as e:CODE
MEDIUM…tions/connectors/source-okta/source_okta/components.py55def refresh_access_token(self) -> Tuple[str, int]:CODE
LOW…onnectors/source-freshcaller/source_freshcaller/run.py28 except Exception as error:CODE
LOW…connectors/source-couchbase/source_couchbase/source.py51 except Exception as e:CODE
LOW…connectors/source-couchbase/source_couchbase/source.py62 except Exception as e:CODE
LOW…ors/source-facebook-pages/source_facebook_pages/run.py26 except Exception as error:CODE
LOW…rce-facebook-pages/source_facebook_pages/components.py51 except Exception as e:CODE
LOW…rce-outbrain-amplify/source_outbrain_amplify/source.py1141 except Exception as e:CODE
LOW…s/source-azure-table/source_azure_table/azure_table.py71 except Exception as e:CODE
LOW…s/source-azure-table/source_azure_table/azure_table.py89 except Exception as e:CODE
LOW…s/source-azure-table/source_azure_table/azure_table.py100 except Exception as e:CODE
LOW…ectors/source-azure-table/source_azure_table/source.py56 except Exception as e:CODE
LOW…ectors/source-azure-table/source_azure_table/source.py94 except Exception as e:CODE
LOW…ectors/source-azure-table/source_azure_table/source.py128 except Exception as e:CODE
LOW…stination-pgvector/destination_pgvector/destination.py72 except Exception as e:CODE
LOW…ector/destination_pgvector/common/sql/sql_processor.py83 except Exception as ex:CODE
LOW…ector/destination_pgvector/common/sql/sql_processor.py308 except Exception as ex:CODE
LOW…nnectors/source-tplcentral/source_tplcentral/source.py68 except Exception as e:CODE
LOW…nnectors/source-tplcentral/source_tplcentral/source.py85 except Exception as e:CODE
MEDIUM…nnectors/source-tplcentral/source_tplcentral/source.py60def refresh_access_token(self) -> Tuple[str, int]:CODE
LOW…s/connectors/source-commcare/source_commcare/source.py54 except Exception as ex:CODE
LOW…s/connectors/source-commcare/source_commcare/source.py119 except Exception:CODE
LOW…e-integrations/connectors/source-klaviyo/components.py260 except Exception as e:CODE
LOW…ination-sftp-json/destination_sftp_json/destination.py78 except Exception as e:CODE
LOW…rce-google-directory/source_google_directory/client.py39 except Exception as error:CODE
LOW…stination-firebolt/destination_firebolt/destination.py141 except Exception as e:CODE
LOW…e-integrations/connectors/source-younium/components.py87 except Exception as e:CODE
LOW…google-sheets/destination_google_sheets/destination.py38 except Exception as err:CODE
LOW…tion-google-sheets/destination_google_sheets/client.py47 except Exception as e:CODE
LOW…nectors/destination-astra/destination_astra/indexer.py84 except Exception as e:CODE
MEDIUM…nectors/destination-astra/destination_astra/indexer.py73def check(self) -> Optional[str]:CODE
LOW…rs/destination-astra/destination_astra/astra_client.py43 except Exception:CODE
LOW…/connectors/source-mixpanel/unit_tests/test_streams.py642 except Exception as e:CODE
LOW…ions/connectors/source-mixpanel/source_mixpanel/run.py29 except Exception as error:CODE
LOW…s/destination-sqlite/destination_sqlite/destination.py143 except Exception as e:STRING
LOW…tors/destination-vectara/destination_vectara/client.py82 except Exception as e:CODE
LOW…egrations/connectors/source-kyve/source_kyve/source.py32 except Exception as e:CODE
LOW…/connectors/source-amazon-seller-partner/components.py323 except Exception as e:CODE
216 more matches not shown…
Fake / Example Data263 hits · 270 pts
SeverityFileLineSnippetContext
LOW…nation/dynamodb/DynamodbDestinationAcceptanceTest.java56 ((ObjectNode) failCheckJson).put("access_key_id", "fake-key");CODE
LOW…onnectors/destination-rabbitmq/unit_tests/unit_test.py93 data = {"name": "John Doe", "email": "john.doe@example.com"}CODE
LOW…onnectors/destination-rabbitmq/unit_tests/unit_test.py110 data = {"name": "John Doe", "email": "john.doe@example.com"}CODE
LOW…s/connectors/source-iterable/unit_tests/test_source.py34 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.py205 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.py230 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.py257 responses.get(expected_url_base + "lists/getUsers?listId=1", body="user@example.com")CODE
LOW…nnectors/source-iterable/unit_tests/test_extractors.py15 b'{"itblInternal": 1, "_type": "event", "createdAt": "2024-03-21", "email": "user@example.com", "data": {"event_CODE
LOW…nnectors/source-iterable/unit_tests/test_extractors.py31 "email": "user@example.com",CODE
LOW…esk-chat/unit_tests/resource/http/response/agents.json6 "display_name": "John Doe",CODE
LOW…grations/connectors/source-okta/unit_tests/conftest.py54 "name": "fake_name",CODE
LOW…grations/connectors/source-okta/unit_tests/conftest.py90 "name": "fake_name",CODE
LOW…s/source-jira/unit_tests/responses/issue_comments.json81 "text": "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque eget venenatis elit. DuisCODE
LOW…s/source-jira/unit_tests/responses/issue_comments.json81 "text": "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Pellentesque eget venenatis elit. DuisCODE
LOW…tors/source-jira/integration_tests/invalid_config.json3 "email": "test@test.com",CODE
LOW…s/connectors/source-azure-table/unit_tests/conftest.py16 return {"storage_account_name": "dummy-value", "storage_access_key": "dummy-value", "storage_endpoint_suffix": "dummCODE
LOW…laviyo/unit_tests/resource/http/response/profiles.json19 "address1": "123 Main St",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py427 "refresh_token": "dummy_token",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py428 "lwa_app_id": "dummy_id",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py441 "refresh_token": "dummy_token",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py442 "lwa_app_id": "dummy_id",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py455 "refresh_token": "dummy_token",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py456 "lwa_app_id": "dummy_id",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py468 "refresh_token": "dummy_token",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py469 "lwa_app_id": "dummy_id",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py483 "refresh_token": "dummy_token",CODE
LOW…source-amazon-seller-partner/unit_tests/test_source.py484 "lwa_app_id": "dummy_id",CODE
LOW…ests/resource/http/response/shipping_zone_methods.json19 "placeholder": ""CODE
LOW…ests/resource/http/response/shipping_zone_methods.json29 "placeholder": ""CODE
LOW…commerce/unit_tests/resource/http/response/orders.json26 "address_1": "123 Main St",CODE
LOW…commerce/unit_tests/resource/http/response/orders.json33 "phone": "555-1234"CODE
LOW…commerce/unit_tests/resource/http/response/orders.json39 "address_1": "123 Main St",CODE
LOW…merce/unit_tests/resource/http/response/customers.json17 "address_1": "123 Main St",CODE
LOW…merce/unit_tests/resource/http/response/customers.json24 "phone": "555-1234"CODE
LOW…merce/unit_tests/resource/http/response/customers.json30 "address_1": "123 Main St",CODE
LOW…nit_tests/resource/http/response/payment_gateways.json20 "placeholder": ""CODE
LOW…unit_tests/resource/http/response/product_reviews.json10 "reviewer": "John Doe",CODE
LOW…e-typeform/integration_tests/invalid_config_oauth.json3 "access_token": "fake-token",CODE
LOW…/source-typeform/integration_tests/invalid_config.json2 "token": "fake-token",CODE
LOW…tors/destination-ragie/unit_tests/test_ragie_config.py15 api_key="dummy_key",CODE
LOW…tors/destination-ragie/unit_tests/test_ragie_config.py39 self.assertEqual(self.mock_config.api_key, "dummy_key")CODE
LOW…destination-ragie/unit_tests/test_ragie_destination.py28 "api_key": "dummy-key",CODE
LOW…estination-starburst-galaxy/sample_secrets/config.json5 "username": "user@example.com",CODE
LOW…nation-starburst-galaxy/src/test/resources/config.json5 "username": "user@example.com",CODE
LOW…tination-starburst-galaxy/src/main/resources/spec.json42 "examples": ["user@example.com"],CODE
LOW…galaxy/StarburstGalaxyS3DestinationAcceptanceTest.java38 .put(S_3_ACCESS_KEY_ID, "fake-key")CODE
LOW…ns/connectors/source-salesforce/unit_tests/api_test.py369 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.py447 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.py39 "email": "test@test.com",CODE
LOW…sts/resource/http/response/issuing_authorizations.json28 "line1": "123 Main Street",CODE
LOW…e/unit_tests/resource/http/response/issuing_cards.json18 "line1": "123 Main Street",CODE
LOW…e/unit_tests/resource/http/response/issuing_cards.json30 "name": "John Doe",CODE
LOW…connectors/source-slack/sample_files/openapi_spec.json2928 "name": "Acme Corp"CODE
LOW…connectors/source-slack/sample_files/openapi_spec.json2933 "name": "Jane Doe"CODE
LOW…unit_tests/resource/http/response/payment_methods.json11 "company_name": "Acme Corp",CODE
LOW…unit_tests/resource/http/response/payment_methods.json13 "name": "Jane Doe",CODE
LOW…/postgres/legacy/AbstractPostgresSourceDatatypeTest.kt905 .addInsertValues("'{lorem ipsum,dolor sit,amet}'")CODE
LOW…/postgres/legacy/AbstractPostgresSourceDatatypeTest.kt906 .addExpectedValues("[\"lorem ipsum\",\"dolor sit\",\"amet\"]")CODE
LOW…nnectors/destination-cumulio/unit_tests/test_client.py85def test_batch_write_append_no_existing_dataset(cumulio_client: CumulioClient, dummy_data: Mapping[str, Any]):CODE
LOW…nnectors/destination-cumulio/unit_tests/test_client.py94 write_buffer=dummy_data["data"],CODE
203 more matches not shown…
Self-Referential Comments77 hits · 220 pts
SeverityFileLineSnippetContext
MEDIUMtools/bin/cdk-auto-release/update-changelog.sh182 # Create a temporary file securelyCOMMENT
MEDIUMtools/bin/cdk-auto-release/update-changelog.sh363 # Define the standard message here, could be made a script argument laterCOMMENT
MEDIUM…schema_generator/schema_generator/configure_catalog.py30 # Create a dictionary representation of the configured catalogCOMMENT
MEDIUM…/source-shopify/unit_tests/test_cached_stream_state.py11# Define the Stream instances for the testsCOMMENT
MEDIUM…e-shopify/source_shopify/shopify_graphql/bulk/query.py2583 # Create a dictionary to map the 'url' key in imagesCOMMENT
MEDIUM…byte-integrations/connectors/source-jira/manifest.yaml14670# Defining a value here is difficult because the Jira API documentation mentions "REST API rate limits are not publishedCOMMENT
MEDIUM…ce-google-sheets/unit_tests/integration/test_source.py977 # Define a non-matching overrideCOMMENT
MEDIUM…ce-google-sheets/unit_tests/integration/test_source.py1081 # Define the schema fields and configured catalog with a primary keyCOMMENT
MEDIUM…ation_pgvector/common/destinations/record_processor.py187 # Create a queue to store output messagesCOMMENT
MEDIUM…ector/destination_pgvector/common/sql/sql_processor.py905 # Create a dictionary mapping columns in users_final to users_stage for updatingSTRING
MEDIUM…ector/destination_pgvector/common/sql/sql_processor.py924 # Define a join between temp_table and final_tableSTRING
MEDIUM…ector/destination_pgvector/common/sql/sql_processor.py927 # Define a condition that checks for records in temp_table that do not have a correspondingSTRING
MEDIUM…s/connectors/source-commcare/source_commcare/source.py316 # Create the streams from the collected namesCOMMENT
MEDIUM…ns/connectors/source-mixpanel/source_mixpanel/utils.py51 # Define the list of fields that might contain date and time values.COMMENT
MEDIUM…ions/connectors/source-bing-ads/unit_tests/conftest.py185 # Create a zip file containing the CSV file directly (without gzip compression)COMMENT
MEDIUM…/connectors/source-bing-ads/unit_tests/test_reports.py315 # Create the full config with custom_reportsCOMMENT
MEDIUM…s/source-bing-ads/unit_tests/integrations/base_test.py40 # Create a zip file containing the CSV file directly (without gzip compression)COMMENT
MEDIUM…s/destination-couchbase/unit_tests/test_destination.py51 # Create a mock scope with no collections initiallyCOMMENT
MEDIUM…ination-couchbase/destination_couchbase/destination.py62 # Create a temporary collection for testingCOMMENT
MEDIUM…destination-ragie/unit_tests/test_ragie_destination.py36 # Create a test streamCOMMENT
MEDIUM…tors/destination-ragie/unit_tests/test_ragie_writer.py36 # Create a stream with proper AirbyteStream objectCOMMENT
MEDIUM…connectors/source-google-ads/unit_tests/test_source.py214 # Create a fake customer_client_streamCOMMENT
MEDIUM…ectors/source-google-ads/unit_tests/test_google_ads.py270 # Define the fields we want metadata forCOMMENT
MEDIUM…ation-motherduck/destination_motherduck/destination.py396 # Create a dummy catalog to check if the SQL processor worksCOMMENT
MEDIUM…tors/source-salesforce/source_salesforce/exceptions.py12 # Define the instance of the Native Airbyte LoggerCOMMENT
MEDIUM…nnectors/destination-cumulio/unit_tests/test_client.py23 # Create a mock configuration dictionaryCOMMENT
MEDIUM…tegrations/connectors/source-s3/source_s3/v4/source.py206 # The following function will wrap the execution in proper error handling.COMMENT
MEDIUM…owflake_cortex/common/destinations/record_processor.py190 # Create a queue to store output messagesCOMMENT
MEDIUM…stination_snowflake_cortex/common/sql/sql_processor.py923 # Create a dictionary mapping columns in users_final to users_stage for updatingSTRING
MEDIUM…stination_snowflake_cortex/common/sql/sql_processor.py942 # Define a join between temp_table and final_tableSTRING
MEDIUM…stination_snowflake_cortex/common/sql/sql_processor.py945 # Define a condition that checks for records in temp_table that do not have a correspondingSTRING
MEDIUM…on-http-tutorial/source_python_http_tutorial/source.py64 # This method is called once for each record returned from the API to compare the cursor field value in that recCOMMENT
MEDIUM…s/source-zendesk-support/unit_tests/test_components.py57 # Create an instance of the extractorCOMMENT
MEDIUM…s/source-zendesk-support/unit_tests/test_components.py90 # Create an instance of the extractorCOMMENT
MEDIUM…-zendesk-support/unit_tests/mock_server/test_topics.py66 # Create the next page request first - this URL will be used in links.nextCOMMENT
MEDIUM…sk-support/unit_tests/mock_server/test_custom_roles.py52 # Create a record with updated_at timestamp after start_date so it passes the date filterCOMMENT
MEDIUM…-zendesk-support/unit_tests/mock_server/test_brands.py91 # Create the next page request first - this URL will be used in links.nextCOMMENT
MEDIUM…ce-zendesk-support/unit_tests/mock_server/test_tags.py51 # Create the next page request first - this URL will be used in links.nextCOMMENT
MEDIUM…endesk-support/unit_tests/mock_server/test_sections.py54 # Create the next page request first - this URL will be used in links.nextCOMMENT
MEDIUM…desk-support/unit_tests/mock_server/test_categories.py54 # Create the next page request first - this URL will be used in links.nextCOMMENT
MEDIUM…esk-support/unit_tests/mock_server/test_automations.py51 # Create the next page request first - this URL will be used in links.nextCOMMENT
MEDIUM…e-zendesk-support/unit_tests/mock_server/test_posts.py60 # Create the next page request first - this URL will be used in links.nextCOMMENT
MEDIUM…-microsoft-sharepoint/unit_tests/test_stream_reader.py332 # Create a mock response for requests.headCOMMENT
MEDIUM…-microsoft-sharepoint/unit_tests/test_stream_reader.py291 # Create a mock response for requests.headCOMMENT
MEDIUM…-microsoft-sharepoint/unit_tests/test_stream_reader.py297 # Create a mock response for requests.getCOMMENT
MEDIUM…-microsoft-sharepoint/unit_tests/test_stream_reader.py355 # Create a mock response for requests.headCOMMENT
MEDIUM…-microsoft-sharepoint/unit_tests/test_stream_reader.py399 # Create a mock structure of folders and filesCOMMENT
MEDIUM…-microsoft-sharepoint/unit_tests/test_stream_reader.py687 # Create an instance of the reader and set its config mockCOMMENT
MEDIUM…tors/source-github/source_github/backoff_strategies.py22 # This method is called if we run into the rate limit. GitHub limits requests to 5000 per hour and providesCOMMENT
MEDIUM…lk/unit_tests/test_stream_reader_directory_matching.py169 # Create a mock SFTP clientCOMMENT
MEDIUM…source-facebook-marketing/unit_tests/test_async_job.py742 # Create a mock that always returns Job Failed statusCOMMENT
MEDIUM…source-facebook-marketing/unit_tests/test_async_job.py774 # Create a mock that completes immediately but fails on get_resultCOMMENT
MEDIUM…source-facebook-marketing/unit_tests/test_async_job.py806 # Create a mock that completes immediately and returns no IDsCOMMENT
MEDIUM…source-facebook-marketing/unit_tests/test_async_job.py838 # Create a mock that is always running (never completes)COMMENT
MEDIUM…ization/integration_tests/test_sparse_nested_fields.py88 # Create the test folder with dbt project and appropriate destination settings to run integration tests fromCOMMENT
MEDIUM…base-normalization/integration_tests/test_ephemeral.py113 # Create the test folder with dbt project and appropriate destination settings to run integration tests fromCOMMENT
MEDIUM…-normalization/integration_tests/test_normalization.py98 # Create the test folder with dbt project and appropriate destination settings to run integration tests fromCOMMENT
MEDIUM…test_output/duckdb/test_nested_streams/dbt_project.yml1# This file is necessary to install dbt-utils with dbt depsCOMMENT
MEDIUM…test_output/duckdb/test_simple_streams/dbt_project.yml1# This file is necessary to install dbt-utils with dbt depsCOMMENT
MEDIUM…_test_output/mssql/test_nested_streams/dbt_project.yml1# This file is necessary to install dbt-utils with dbt depsCOMMENT
17 more matches not shown…
Deep Nesting192 hits · 184 pts
SeverityFileLineSnippetContext
LOWtools/bin/identify-dormant-workflows.py46CODE
LOWtools/bin/cleanup-workflow-runs.py48CODE
LOW…connectors/source-appsflyer/source_appsflyer/source.py104CODE
LOW…egrations/connectors/source-cart/source_cart/source.py88CODE
LOW…egrations/connectors/source-cart/source_cart/source.py92CODE
LOW…egrations/connectors/source-linkedin-ads/components.py252CODE
LOW…egrations/connectors/source-linkedin-ads/components.py42CODE
LOW…egrations/connectors/source-linkedin-ads/components.py331CODE
LOW…nnectors/source-linkedin-ads/unit_tests/test_source.py69CODE
LOW…/connectors/source-stock-ticker-api-tutorial/source.py156CODE
LOW…lob-storage/source_azure_blob_storage/stream_reader.py125CODE
LOW…stination-rabbitmq/destination_rabbitmq/destination.py40CODE
LOW…ions/connectors/source-shopify/source_shopify/utils.py136CODE
LOW…e-shopify/source_shopify/shopify_graphql/bulk/query.py855CODE
LOW…rce-shopify/source_shopify/shopify_graphql/bulk/job.py316CODE
LOW…ctors/source-shopify/source_shopify/streams/streams.py564CODE
LOW…ctors/source-shopify/source_shopify/streams/streams.py817CODE
LOW…/source-shopify/source_shopify/streams/base_streams.py271CODE
LOW…/source-shopify/source_shopify/streams/base_streams.py365CODE
LOW…endesk-chat/unit_tests/mock_server/response_builder.py346CODE
LOW…ation-amazon-sqs/destination_amazon_sqs/destination.py127CODE
LOW…rce-facebook-pages/source_facebook_pages/components.py82CODE
LOW…integrations/connectors/source-us-census/components.py52CODE
LOW…integrations/connectors/source-us-census/components.py159CODE
LOW…ogle-analytics-v4/source_google_analytics_v4/source.py285CODE
LOW…ogle-analytics-v4/source_google_analytics_v4/source.py338CODE
LOW…ation_pgvector/common/destinations/record_processor.py214CODE
LOW…ector/destination_pgvector/common/sql/sql_processor.py677CODE
LOW…ations/connectors/source-faker/source_faker/streams.py155CODE
LOW…s/connectors/source-commcare/source_commcare/source.py293CODE
LOW…e-integrations/connectors/source-klaviyo/components.py229CODE
LOW…ination-sftp-json/destination_sftp_json/destination.py17CODE
LOW…integrations/connectors/source-instagram/components.py304CODE
LOW…stination-firebolt/destination_firebolt/destination.py77CODE
LOW…ns/connectors/source-mixpanel/source_mixpanel/utils.py41CODE
LOW…nnectors/source-mixpanel/source_mixpanel/components.py179CODE
LOW…s/destination-sqlite/destination_sqlite/destination.py37CODE
LOW…tors/destination-vectara/destination_vectara/client.py171CODE
LOW…egrations/connectors/source-kyve/source_kyve/stream.py104CODE
LOW…/connectors/source-amazon-seller-partner/components.py251CODE
LOW…/connectors/source-amazon-seller-partner/components.py907CODE
LOW…-integrations/connectors/source-bing-ads/components.py142CODE
LOW…-integrations/connectors/source-bing-ads/components.py497CODE
LOW…-integrations/connectors/source-typeform/components.py27CODE
LOW…ination-couchbase/destination_couchbase/destination.py86CODE
LOW…ination-couchbase/destination_couchbase/destination.py214CODE
LOW…ination-couchbase/destination_couchbase/destination.py266CODE
LOW…ination-couchbase/destination_couchbase/destination.py345CODE
LOW…ination-couchbase/destination_couchbase/destination.py367CODE
LOW…ination-couchbase/destination_couchbase/destination.py387CODE
LOW…ns/connectors/source-firebolt/source_firebolt/utils.py76CODE
LOW…s/connectors/source-firebolt/source_firebolt/source.py81CODE
LOW…ions/connectors/source-fauna/source_fauna/serialize.py26CODE
LOW…rations/connectors/source-fauna/source_fauna/source.py206CODE
LOW…rations/connectors/source-fauna/source_fauna/source.py573CODE
LOW…ns/connectors/source-fauna/unit_tests/discover_test.py30CODE
LOW…-integrations/connectors/source-intercom/components.py57CODE
LOW…n-aws-datalake/destination_aws_datalake/destination.py36CODE
LOW…aws-datalake/destination_aws_datalake/stream_writer.py69CODE
LOW…aws-datalake/destination_aws_datalake/stream_writer.py118CODE
132 more matches not shown…
Decorative Section Separators54 hits · 178 pts
SeverityFileLineSnippetContext
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py73# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py75# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py188# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py190# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py274# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py276# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py21# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py24# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py39# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py41# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py101# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py103# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py128# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py130# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py154# ---------------------------------------------------------------------------COMMENT
MEDIUM…ors/source-iterable/unit_tests/test_lookback_window.py156# ---------------------------------------------------------------------------COMMENT
MEDIUM…/connectors/source-amazon-seller-partner/components.py132 # ------------------------------------------------------------------COMMENT
MEDIUM…/connectors/source-amazon-seller-partner/components.py134 # ------------------------------------------------------------------COMMENT
MEDIUM…/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt44 // ── helpers ──────────────────────────────────────────────────────────────────COMMENT
MEDIUM…/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt70 // ── validateTimestamp ────────────────────────────────────────────────────────COMMENT
MEDIUM…/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt112 // ── validateInteger ─────────────────────────────────────────────────────────COMMENT
MEDIUM…/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt161 // ── validateNumber ──────────────────────────────────────────────────────────COMMENT
MEDIUM…/destination/mssql/v2/convert/MSSQLValueCoercerTest.kt193 // ── coerce ──────────────────────────────────────────────────────────────────COMMENT
MEDIUM…er-io/unit_tests/test_pagination_region_incremental.py229# ---------------------------------------------------------------------------COMMENT
MEDIUM…er-io/unit_tests/test_pagination_region_incremental.py231# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py23# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py25# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py56# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py58# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py92# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py94# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py182# ---------------------------------------------------------------------------COMMENT
MEDIUM…/source-s3/unit_tests/v4/test_availability_strategy.py184# ---------------------------------------------------------------------------COMMENT
MEDIUM…connectors/source-gcs/unit_tests/test_stream_reader.py200# ---------------------------------------------------------------------------COMMENT
MEDIUM…connectors/source-gcs/unit_tests/test_stream_reader.py202# ---------------------------------------------------------------------------COMMENT
MEDIUM…rations/enterprise-connectors/source-db2-enterprise.md112# ===============================================COMMENT
MEDIUM…rations/enterprise-connectors/source-db2-enterprise.md115# ===============================================COMMENT
MEDIUM.github/workflows/agent-sdk-docs-generate.yml149 # ── Build symbol index ──────────────────────────────────────COMMENT
MEDIUM.github/workflows/agent-sdk-docs-generate.yml165 # ── Add anchors and resolve links ───────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml61 # ── Validate inputs ──────────────────────────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml69 # ── Authenticate as Octavia Bot (creates PRs, triggers CI) ──────COMMENT
MEDIUM.github/workflows/block-release.yml90 # ── Validate connector directory exists ─────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml99 # ── Install airbyte-ops CLI ───────────────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml106 # ── Block: create marker file via CLI ────────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml117 # ── Unblock: remove marker file via CLI ──────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml128 # ── Create and force-merge PR ──────────────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml157 # ── Force-merge using admin bot ────────────────────────────────COMMENT
MEDIUM.github/workflows/block-release.yml188 # ── Summary ────────────────────────────────────────────────────COMMENT
MEDIUM.github/workflows/hydra-automerge.yml54 # ── Authentication ──────────────────────────────────────────────COMMENT
MEDIUM.github/workflows/hydra-automerge.yml64 # ── Pre-checks ─────────────────────────────────────────────────COMMENT
MEDIUM.github/workflows/hydra-automerge.yml215 # ── Devin AI evaluation ────────────────────────────────────────COMMENT
MEDIUM.github/workflows/hydra-automerge.yml261 # ── Evaluate structured output ─────────────────────────────────COMMENT
MEDIUM.github/workflows/hydra-automerge.yml310 # ── Post results ───────────────────────────────────────────────COMMENT
MEDIUM.github/workflows/hydra-automerge.yml404 # ── Merge (if evaluation passed and not dry-run) ────────────────COMMENT
Modern Structural Boilerplate140 hits · 142 pts
SeverityFileLineSnippetContext
LOW…nnectors/source-appsflyer/source_appsflyer/__init__.py8__all__ = ["SourceAppsflyer"]CODE
LOW…rations/connectors/source-cart/source_cart/__init__.py27__all__ = ["SourceCart", "CentralAPIHeaderAuthenticator", "CustomHeaderAuthenticator"]CODE
LOW…nnectors/source-linkedin-ads/unit_tests/test_source.py72 def update_with_cache_parent_configs(parent_configs: list[dict[str, Any]]) -> None:CODE
LOW…egrations/connectors/source-rss/source_rss/__init__.py8__all__ = ["SourceRss"]CODE
LOW…ure-blob-storage/source_azure_blob_storage/__init__.py10__all__ = ["SourceAzureBlobStorage", "SourceAzureBlobStorageStreamReader", "SourceAzureBlobStorageSpec"]CODE
LOW…/source-commercetools/source_commercetools/__init__.py8__all__ = ["SourceCommercetools"]CODE
LOW…/destination-rabbitmq/destination_rabbitmq/__init__.py8__all__ = ["DestinationRabbitmq"]CODE
LOW…nnectors/destination-kvdb/destination_kvdb/__init__.py26__all__ = ["DestinationKvdb"]CODE
LOW…connectors/source-iterable/source_iterable/__init__.py3__all__ = ["SourceIterable"]CODE
LOW…e-shopify/unit_tests/integration/api/authentication.py16def set_up_shop(http_mocker: HttpMocker, shop_name: str) -> None:CODE
LOW…s/connectors/source-shopify/source_shopify/__init__.py27__all__ = ["SourceShopify"]CODE
LOW…rce-shopify/source_shopify/shopify_graphql/bulk/job.py218 def _set_checkpointing(self) -> None:CODE
LOW…rce-shopify/source_shopify/shopify_graphql/bulk/job.py226 def _set_last_checkpoint_cursor_value(self, checkpointed_cursor: str) -> None:CODE
LOW…-shopify/source_shopify/shopify_graphql/bulk/record.py125 def _set_parent_state_value(self, value: str | int) -> None:CODE
LOW…tors/destination-chroma/destination_chroma/__init__.py8__all__ = ["DestinationChroma"]CODE
LOW…tination-amazon-sqs/destination_amazon_sqs/__init__.py8__all__ = ["DestinationAmazonSqs"]CODE
LOW…rations/connectors/source-okta/source_okta/__init__.py8__all__ = ["SourceOkta", "components"]CODE
LOW…tors/source-freshcaller/source_freshcaller/__init__.py8__all__ = ["SourceFreshcaller"]CODE
LOW…nnectors/source-couchbase/source_couchbase/__init__.py8__all__ = ["SourceCouchbase"]CODE
LOW…ource-facebook-pages/source_facebook_pages/__init__.py8__all__ = ["SourceFacebookPages"]CODE
LOW…e-outbrain-amplify/source_outbrain_amplify/__init__.py8__all__ = ["SourceOutbrainAmplify"]CODE
LOW…gle-sheets/unit_tests/integration/conftest/__init__.py11__all__ = [CODE
LOW…tors/source-azure-table/source_azure_table/__init__.py8__all__ = ["SourceAzureTable"]CODE
LOW…le-analytics-v4/source_google_analytics_v4/__init__.py28__all__ = ["SourceGoogleAnalyticsV4"]CODE
LOW…/destination-pgvector/destination_pgvector/__init__.py8__all__ = ["DestinationPGVector"]CODE
LOW…ation_pgvector/common/destinations/record_processor.py300 def _setup(self) -> None: # noqa: B027 # Intentionally empty, not abstractCODE
LOW…tions/connectors/source-faker/source_faker/__init__.py8__all__ = ["SourceFaker"]CODE
LOW…ectors/source-tplcentral/source_tplcentral/__init__.py28__all__ = ["SourceTplcentral"]CODE
LOW…s/connectors/source-zenloop/source_zenloop/__init__.py8__all__ = ["SourceZenloop"]CODE
LOW…connectors/source-commcare/source_commcare/__init__.py8__all__ = ["SourceCommcare"]CODE
LOW…e-integrations/connectors/source-klaviyo/components.py178 def _set_recipient_count(self, record: Mapping[str, Any]) -> None:CODE
LOW…e-integrations/connectors/source-klaviyo/components.py190 def _set_campaign_message(self, record: Mapping[str, Any]) -> None:CODE
LOW…estination-sftp-json/destination_sftp_json/__init__.py8__all__ = ["DestinationSftpJson"]CODE
LOW…e-google-directory/source_google_directory/__init__.py6__all__ = ["SourceGoogleDirectory"]CODE
LOW…ons/connectors/source-instagram/unit_tests/__init__.py7__all__ = ["get_source", "read_full_refresh", "read_incremental"]CODE
LOW…ectors/source-amazon-sqs/source_amazon_sqs/__init__.py9__all__ = ["SourceAmazonSqs"]CODE
LOW…/destination-firebolt/destination_firebolt/__init__.py8__all__ = ["DestinationFirebolt"]CODE
LOW…on-google-sheets/destination_google_sheets/__init__.py8__all__ = ["DestinationGoogleSheets"]CODE
LOW…s/connectors/source-genesys/source_genesys/__init__.py8__all__ = ["SourceGenesys"]CODE
LOW…ons/connectors/source-looker/source_looker/__init__.py3__all__ = ["SourceLooker"]CODE
LOW…ectors/destination-astra/destination_astra/__init__.py8__all__ = ["DestinationAstra"]CODE
LOW…tors/source-public-apis/source_public_apis/__init__.py8__all__ = ["SourcePublicApis"]CODE
LOW…connectors/source-mixpanel/source_mixpanel/__init__.py27__all__ = ["SourceMixpanel"]CODE
LOW…tors/destination-sqlite/destination_sqlite/__init__.py8__all__ = ["DestinationSqlite"]CODE
LOW…rs/destination-vectara/destination_vectara/__init__.py8__all__ = ["DestinationVectara"]CODE
LOW…rations/connectors/source-kyve/source_kyve/__init__.py8__all__ = ["SourceKyve"]CODE
LOW…-integrations/connectors/source-bing-ads/components.py28logger = logging.getLogger(__name__)CODE
LOW…crosoft-onedrive/source_microsoft_onedrive/__init__.py8__all__ = ["SourceMicrosoftOneDrive"]CODE
LOW…estination-couchbase/destination_couchbase/__init__.py8__all__ = ["DestinationCouchbase"]CODE
LOW…s/connectors/source-webflow/source_webflow/__init__.py8__all__ = ["SourceWebflow"]CODE
LOW…connectors/source-firebolt/source_firebolt/__init__.py8__all__ = ["SourceFirebolt"]CODE
LOW…e-box-data-extract/source_box_data_extract/__init__.py8__all__ = ["SourceBoxDataExtract"]CODE
LOW…tions/connectors/source-fauna/source_fauna/__init__.py8__all__ = ["SourceFauna"]CODE
LOW…ons/connectors/source-gridly/source_gridly/__init__.py8__all__ = ["SourceGridly"]CODE
LOW…tion-aws-datalake/destination_aws_datalake/__init__.py26__all__ = ["DestinationAwsDatalake"]CODE
LOW…ons/connectors/source-adjust/source_adjust/__init__.py8__all__ = ["SourceAdjust", "components"]CODE
LOW…tors/destination-deepset/destination_deepset/models.py16__all__ = [CODE
LOW…rs/destination-deepset/destination_deepset/__init__.py9__all__ = ["DestinationDeepset"]CODE
LOW…ors/destination-deepset/unit_tests/test_destination.py68def _setup(monkeypatch: pytest.MonkeyPatch, client: DeepsetCloudApi) -> None:CODE
LOW…ectors/destination-ragie/destination_ragie/__init__.py10__all__ = ["DestinationRagie", "RagieWriter"]CODE
80 more matches not shown…
Magic Placeholder Names25 hits · 128 pts
SeverityFileLineSnippetContext
HIGH…/source-news-api/integration_tests/invalid_config.json2 "api_key": "YOUR_API_KEY",CODE
HIGH…s/source-news-api/integration_tests/sample_config.json2 "api_key": "YOUR_API_KEY",CODE
HIGH…ctors/source-oura/integration_tests/sample_config.json2 "api_key": "YOUR_API_KEY",CODE
HIGH…rce-alpha-vantage/integration_tests/sample_config.json2 "api_key": "YOUR_API_KEY",CODE
HIGH…rce-northpass-lms/integration_tests/sample_config.json2 "api_key": "your-api-key"CODE
HIGH…ntegrations/connectors/source-salesflare/manifest.yaml372 description: "Enter you api key like this : Bearer YOUR_API_KEY"CODE
HIGH…stination-customer-io/src/main/resources/manifest.yaml28 Enter your Customer IO <a href="https://docs.customer.io/integrations/sdk/ios/getting-started/auth/#get-yoCODE
HIGH…stination-customer-io/src/main/resources/manifest.yaml37 Enter your Customer IO <a href="https://docs.customer.io/integrations/sdk/ios/getting-started/auth/#get-yoCODE
HIGH…/src/test-integration/resources/expected-spec-oss.json18 "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-starCODE
HIGH…/src/test-integration/resources/expected-spec-oss.json26 "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-starCODE
HIGH…rc/test-integration/resources/expected-spec-cloud.json18 "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-starCODE
HIGH…rc/test-integration/resources/expected-spec-cloud.json26 "description" : "Enter your Customer IO <a href=\"https://docs.customer.io/integrations/sdk/ios/getting-starCODE
HIGH…/source-amplitude/integration_tests/sample_config.json3 "api_key": "<your_api_key>",CODE
HIGH…rs/source-paypal-transaction/bin/payments_generator.py24# '{"actor":{"account_number":"<ACCOUNT_ID>","party_id":"<PARTY_ID>","auth_claims":["AUTHORIZATION_CODE"],"auth_state":"COMMENT
HIGH…urce-emailoctopus/integration_tests/sample_config.json2 "api_key": "your_api_key"CODE
HIGH…/source-chargebee/integration_tests/sample_config.json3 "site_api_key": "<your_api_key>",CODE
HIGH…/source-plausible/integration_tests/sample_config.json2 "api_key": "your_api_key",CODE
HIGH…/source-coin-api/integration_tests/invalid_config.json2 "api_key": "YOUR_API_KEY",CODE
HIGH…s/source-coin-api/integration_tests/sample_config.json2 "api_key": "YOUR_API_KEY",CODE
HIGHdocs/platform/enterprise-flex/log-collection.md162 --set datadog.apiKey=<YOUR_API_KEY> \CODE
HIGHdocs/platform/enterprise-flex/log-collection.md162 --set datadog.apiKey=<YOUR_API_KEY> \CODE
HIGHdocs/integrations/sources/recurly.md58Generate a API key using the [Recurly documentation](https://docs.recurly.com/docs/api-keys#section-find-or-generate-youCODE
HIGHdocs/integrations/sources/mailchimp.md52- To authenticate using an API key for Airbyte Open Source, select **API key** from the Authentication dropdown and enteCODE
HIGHdocs/integrations/sources/salesflare.md10| `api_key` | `string` | API Key. Enter you api key like this : Bearer YOUR_API_KEY | |CODE
HIGH…cs/developers/pyairbyte/reference/airbyte/mcp/index.md40AIRBYTE_CLOUD_CLIENT_ID=your_api_keyCODE
Redundant / Tautological Comments61 hits · 98 pts
SeverityFileLineSnippetContext
LOW…-auto-release/update-bulk-cdk-version-in-connectors.sh12# Check if merge_base could be found (e.g., if branches are unrelated)COMMENT
LOW…-auto-release/update-bulk-cdk-version-in-connectors.sh25# Check if any files were modifiedCOMMENT
LOWtools/bin/cdk-auto-release/update-changelog.sh198 # Check if awk actually produced output (basic sanity check)COMMENT
LOWtools/bin/cdk-auto-release/update-changelog.sh277 # Check if there are changes to commit before committingCOMMENT
LOW…/connectors/source-stock-ticker-api-tutorial/source.py145 # Read the file named spec.json from the module directory as a JSON fileCOMMENT
LOW…ions/connectors/source-shopify/source_shopify/utils.py314 # Check if we have the saved state and keep the minimun valueCOMMENT
LOW…/connectors/source-mixpanel/source_mixpanel/streams.py472 # Set whether to allow additional properties for engage and export endpointsCOMMENT
LOW…/connectors/source-amazon-seller-partner/components.py241 # Check if this is a token expiration error and invalidate the token if soCOMMENT
LOW…ft-onedrive/source_microsoft_onedrive/stream_reader.py183 # Check if the object is a file or a folderCOMMENT
LOW…s/destination-couchbase/unit_tests/test_destination.py118 # Check if collection was createdCOMMENT
LOW…s/destination-couchbase/unit_tests/test_destination.py121 # Check if upsert_multi was called for writing recordsCOMMENT
LOW…s/destination-couchbase/unit_tests/test_destination.py154 # Check if collection was createdCOMMENT
LOW…s/destination-couchbase/unit_tests/test_destination.py157 # 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.py207 # Check if collections were created for both streamsCOMMENT
LOW…s/destination-couchbase/unit_tests/test_destination.py212 # Check if upsert_multi was called for both collectionsCOMMENT
LOW…ination-couchbase/destination_couchbase/destination.py222 # Check if collection existsCOMMENT
LOW…ons/connectors/source-webflow/source_webflow/source.py274 # Loop over the list of records and create a dictionary with name as key, and _id as valueCOMMENT
LOW…ce-box-data-extract/source_box_data_extract/box_api.py107 # Check if any representations existCOMMENT
LOW…aws-datalake/destination_aws_datalake/stream_writer.py344 # Check if nested object has properties and no mixed type objectsCOMMENT
LOW…ion-aws-datalake/integration_tests/integration_test.py155 # Check if table was createdCOMMENT
LOW…ors/source-google-ads/unit_tests/test_empty_streams.py338 # Check if this is a click_view query using regex (case-insensitive)COMMENT
LOW…onnectors/source-google-ads/source_google_ads/utils.py261 # Check if the timeout has been reached without new results.COMMENT
LOW…paypal-transaction/bin/paypal_transaction_generator.py199 # Check if the request was successfulCOMMENT
LOW…nation-surrealdb/integration_tests/integration_test.py49 # Check if surreal command is availableCOMMENT
LOW…-microsoft-sharepoint/unit_tests/test_stream_reader.py320 # Check if the file exists at the file_url pathCOMMENT
LOW…harepoint/source_microsoft_sharepoint/stream_reader.py219 # Check if the object is a file or a folderCOMMENT
LOW…harepoint/source_microsoft_sharepoint/stream_reader.py490 # Write the file to the local directoryCOMMENT
LOW…s/destination-pinecone/destination_pinecone/indexer.py126 # Check if adding the item exceeds the size limitCOMMENT
LOW…/source-pinterest/unit_tests/test_config_migrations.py54 # Check if the condition evaluates to trueCOMMENT
LOW…e-integrations/connectors/source-hubspot/components.py432 # Set it to null to avoid errors on destination' normalization stage.COMMENT
LOW…ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py161 # Check if dir_path could lead to matching filesCOMMENT
LOW…ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py174 # Check if the directory exactly matches the patternCOMMENT
LOW…ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py188 # Check if each directory part matches the corresponding glob partCOMMENT
LOW…ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py196 # Check if this part could match (including wildcards)COMMENT
LOW…r/test_search_analytics_keyword_site_report_by_page.py106 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…r/test_search_analytics_keyword_site_report_by_page.py281 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…r/test_search_analytics_keyword_site_report_by_page.py119 # Check if this is a keyword site report by page requestCOMMENT
LOW…r/test_search_analytics_keyword_site_report_by_page.py348 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…ck_server/test_search_analytics_keyword_page_report.py108 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…ck_server/test_search_analytics_keyword_page_report.py312 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…ck_server/test_search_analytics_keyword_page_report.py121 # Check if this is a keyword page report requestCOMMENT
LOW…ck_server/test_search_analytics_keyword_page_report.py268 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…ck_server/test_search_analytics_keyword_page_report.py379 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…r/test_search_analytics_keyword_site_report_by_site.py106 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…r/test_search_analytics_keyword_site_report_by_site.py302 # Check if this is a parent stream request (search_appearances)COMMENT
LOW…r/test_search_analytics_keyword_site_report_by_site.py119 # Check if this is a keyword site report by site requestCOMMENT
LOW…r/test_search_analytics_keyword_site_report_by_site.py368 # Check if this is a parent stream request (search_appearances)COMMENT
LOW.claude/skills/my-prs/scripts/fetch-prs.sh64 # Check if author is org memberCOMMENT
LOWpoe-tasks/build-and-publish-java-connectors-with-tag.sh76# Check if this is a Java connectorCOMMENT
LOWpoe-tasks/get-modified-connectors.sh164 # Check if it's a Java connector (either with build.gradle or build.gradle.kts)COMMENT
LOWpoe-tasks/publish-python-registry.sh36 # Check if the connector is enabled for PyPI publishingCOMMENT
LOWpoe-tasks/publish-python-registry.sh164# Check if PyPI publishing is enabled in metadataCOMMENT
LOWpoe-tasks/publish-python-registry.sh206 # Check if package already existsCOMMENT
LOW.github/workflows/community-pr-permissions-check.yml42 # Check if fork is from an organizationCOMMENT
LOW.github/workflows/stale-discussions-autoclose.yml80 # Check if last comment is the housekeeping prompt and is older than 14 daysCOMMENT
LOW…hub/workflows/update-connector-cdk-version-command.yml67 # Check if connector uses airbyteBulkConnector pluginCOMMENT
LOW.github/workflows/ai-docs-review-command.yml140 # Check if any files match the connector path patternCOMMENT
LOW.github/workflows/pr-ai-review-submit.yml148 # Check if review was created successfullyCOMMENT
LOW.github/actions/connector-image-build-push/action.yml95 # Check if connector directory existsCOMMENT
LOW.github/actions/connector-image-build-push/action.yml101 # Check if metadata.yaml existsCOMMENT
1 more matches not shown…
AI Slop Vocabulary34 hits · 69 pts
SeverityFileLineSnippetContext
MEDIUM…te-integrations/connectors/source-pretix/manifest.yaml6 [Pretix](https://pretix.eu/about/en/) connector enables seamless dataCODE
MEDIUM…ntegrations/connectors/source-spotlercrm/manifest.yaml6 The Airbyte connector for [Spotler CRM](https://spotler.com/) enables seamlessCODE
MEDIUM…rce-shopify/source_shopify/shopify_graphql/bulk/job.py373 # we leverage the checkpointing in this case.COMMENT
MEDIUM…yte-integrations/connectors/source-nocrm/manifest.yaml6 [NoCRM](https://nocrm.io) connector enables seamless data integration betweenCODE
MEDIUM…ntegrations/connectors/source-amazon-ads/manifest.yaml3772# We've set the default to 12 so we can leverage some concurrency, but this can be tuned as weCOMMENT
MEDIUM…tors/source-pabbly-subscriptions-billing/manifest.yaml7 Billing](https://www.pabbly.com/subscriptions/) enables seamless dataCODE
LOW…rations/connectors/source-fauna/source_fauna/source.py163 # instead [:2] will just return an empty list. The first two values must match toCOMMENT
MEDIUM…-integrations/connectors/source-flexmail/manifest.yaml6 The Airbyte connector for [Flexmail](https://flexmail.be/) enables seamlessCODE
MEDIUM…integrations/connectors/source-papersign/manifest.yaml7 [Papersign](https://paperform.co/products/papersign/) enables seamlessCODE
LOW…estination-ragie/integration_tests/test_integration.py169 # If no real creds, just pass (mocked)COMMENT
LOW…estination-ragie/integration_tests/test_integration.py220 # If no real creds, just pass (mocked)COMMENT
MEDIUM…ation-motherduck/destination_motherduck/destination.py417 """Overridden from CDK base class in order to use the patched SerDes class."""STRING
MEDIUM…e-integrations/connectors/source-campayn/manifest.yaml6 The Airbyte connector for [Campayn](https://campayn.com/) enables seamlessCODE
MEDIUM…integrations/connectors/source-paperform/manifest.yaml6 Airbyte connector for [Paperform](https://paperform.co/) enables seamless dataCODE
MEDIUM…rce-jina-ai-reader/source_jina_ai_reader/manifest.yaml142 Visit https://coding.tools/url-encode for seamless encoding.CODE
LOW…ntegrations/connectors/source-prestashop/components.py139 # If we don't have any fields to check, just return the record as isCOMMENT
LOW…ons/connectors/source-s3/source_s3/v4/stream_reader.py205 # we can simply return the result here as it is a context manager itself that will release all resourcesCOMMENT
LOW…tegrations/connectors/source-s3/source_s3/v4/cursor.py135 # Note: we convert to the v4 cursor granularity, but since no items are in the history we simply use theCOMMENT
MEDIUM…nation-surrealdb/integration_tests/integration_test.py108 # A more robust check (e.g., trying to connect) could be added if necessary.COMMENT
MEDIUM…-integrations/connectors/source-encharge/manifest.yaml6 Airbyte connector for [Encharge](https://encharge.io/) enables seamless dataCODE
LOW…on-http-tutorial/source_python_http_tutorial/source.py60 # so we just return a list containing the responseCOMMENT
MEDIUM…yte-integrations/connectors/source-wufoo/manifest.yaml6 The Airbyte connector for [Wufoo](https://www.wufoo.com/) enables seamlessCODE
LOW…stination-timeplus/destination_timeplus/destination.py70 # for append mode, just add more data to the existing stream. No need to do anything.COMMENT
LOW…rosoft-dataverse/source_microsoft_dataverse/streams.py101 state_checkpoint_interval = None # For now we just use the change tracking as state, and it is only emitted on lastCODE
LOW…integrations/bases/base-java/run_with_normalization.sh44 # so if we remove the `write`, we can just pass the rest directly into normalizationCOMMENT
LOWpoe-tasks/manifest-only-connector-tasks.toml8# manifest-only connector, simply add a `poe_tasks.toml` file in the connector'sCOMMENT
MEDIUM…c/main/kotlin/io/airbyte/cdk/load/data/AirbyteValue.kt76// They're not particularly robust, and probably shouldn't be relied onCOMMENT
MEDIUM…ract/src/main/kotlin/io/airbyte/cdk/read/Partitions.kt184 // pending state and stream status messages. This is done in order to better utilize socketsCOMMENT
MEDIUM…c/main/kotlin/io/airbyte/cdk/load/data/AirbyteValue.kt76// They're not particularly robust, and probably shouldn't be relied onCOMMENT
MEDIUM…/airbyte/cdk/integrations/base/IntegrationCliParser.kt16// todo (cgardens) - use argparse4j.github.io instead of org.apache.commons.cli to leverage betterCOMMENT
LOW…sources/types/ActorDefinitionResourceRequirements.yaml7# set to false because we need the validations on seeds to be strict. otherwise, we will just add whatever is in the seeCOMMENT
LOW…sources/types/ActorDefinitionResourceRequirements.yaml21 # set to false because we need the validations on seeds to be strict. otherwise, we will just add whatever is in theCOMMENT
MEDIUM…rations/destination/staging/GeneralStagingFunctions.kt24 // leverage data that was uploaded to stageCOMMENT
MEDIUM.github/workflows/autodoc.yml38 fetch-depth: 0 # Full history needed for comprehensive analysisCODE
Verbosity Indicators40 hits · 64 pts
SeverityFileLineSnippetContext
LOW…ectors/source-google-ads/unit_tests/test_components.py990 # Step 1: Serialize MESSAGE fieldsCOMMENT
LOW…ectors/source-google-ads/unit_tests/test_components.py998 # Step 2: Flatten nested dictsCOMMENT
LOW…ource-sendgrid/unit_tests/mock_server/test_contacts.py38 # Step 1: Mock the export creation request (POST)COMMENT
LOW…ource-sendgrid/unit_tests/mock_server/test_contacts.py49 # Step 2: Mock the polling request (GET status) - return "ready" statusCOMMENT
LOW…ource-sendgrid/unit_tests/mock_server/test_contacts.py67 # Step 3: Mock the download request - return plain CSV with uppercase field namesCOMMENT
LOW…urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java102 // Step 1: Convert underscores to dashes (matches Debezium's normalizeName behavior)COMMENT
LOW…urce/mongodb/cdc/MongoDbDebeziumPropertiesManager.java105 // Step 2: Replace special characters with underscoresCOMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt376 // Step 1: Create principal and retrieve OAuth credentials (clientId and clientSecret)COMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt401 // Step 2: Create principal role (realm-wide) and catalog role (catalog-specific)COMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt405 // Step 3: Link catalog role to principal role for the specific catalogCOMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt418 // Step 4: Grant required privileges to the catalog roleCOMMENT
LOW…rations/destination/s3_data_lake/PolarisEnvironment.kt424 // Step 5: Attach the principal role to the principal (completes the permission chain)COMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt101 // Step 1: Finalize the gzip CSVCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt116 // Step 2: Upload to S3COMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt119 // Step 3: Execute COPYCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt130 // Step 4: Cleanup S3 staging fileCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt142 // Step 5: Reset stateCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt219 // Step 1: Resolve extended placeholders ({date:<format>}, {timestamp:millis|micro})COMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt241 // Step 2: Resolve standard placeholdersCOMMENT
LOW…estination/redshift/write/load/RedshiftInsertBuffer.kt252 // Step 3: Ensure the file has the correct extension for Redshift COPYCOMMENT
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt229 // Step 1: Materialize deduped rows into a session-scoped temp tableSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt232 // Step 2: CDC hard-delete (if enabled)STRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt251 // Step 3: Update existing rowsSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt254 // Step 4: Insert new rowsSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt257 // Step 5: Drop temp tableSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt482 // Step 1: Add temp column with the new typeSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt484 // Step 2: Cast data from old column to temp columnSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt486 // Step 3: Record DESTINATION_TYPECAST_ERROR in _airbyte_meta for rows whereSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt497 // Step 4: Drop the original columnSTRING
LOW…tions/destination/redshift/sql/RedshiftSqlGenerator.kt499 // Step 5: Rename temp column to the original nameSTRING
LOW…nectors/source-sftp-bulk/integration_tests/conftest.py52 # Step 1: Extract the base CSV file from the ZIP archiveCOMMENT
LOW…nectors/source-sftp-bulk/integration_tests/conftest.py65 # Step 2: Create duplicates with different namesCOMMENT
LOW…ors/source-sftp-bulk/source_sftp_bulk/stream_reader.py172 # we need to check if this directory could be part of a matching pathCOMMENT
LOW…dk/load/dataflow/transform/medium/ProtobufConverter.kt188 // Step 1: Extract raw value from protobuf using the right method based on typeCOMMENT
LOW…dk/load/dataflow/transform/medium/ProtobufConverter.kt191 // Step 2: Decide final target type (check for destination override first)COMMENT
LOW…dk/load/dataflow/transform/medium/ProtobufConverter.kt195 // Step 3: Create AirbyteValue of the target type using the raw valueCOMMENT
LOW.github/workflows/autodoc.yml34 # Step 1: Get the pushed codeCOMMENT
LOW.github/workflows/autodoc.yml40 # Step 2: Analyze what files were changed in this pushCOMMENT
LOW.github/workflows/autodoc.yml77 # Step 3: Check if this push affects a connectorCOMMENT
LOW.github/workflows/autodoc.yml109 # Step 4: Trigger AI documentation update for connector changesCOMMENT
Modern AI Meta-Vocabulary19 hits · 53 pts
SeverityFileLineSnippetContext
MEDIUMREADME.md39- **Giving AI agents, LLMs, or MCP clients real-time access to business data** (CRMs, support tools, SaaS APIs, databaseCODE
MEDIUM…ons/connectors/source-scaffold-java-jdbc/metadata.yaml24 documentationUrl: https://docs.airbyte.com/integrations/sources/scaffold-java-jdbcCODE
MEDIUMdocs/release_notes/self-managed/v-1.0.md35- [Workloads](/platform/understanding-airbyte/jobs#workloads) provide a more scalable and reliable architecture to run sCODE
MEDIUMdocs/platform/understanding-airbyte/tech-stack.md47### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_COMMENT
MEDIUMdocs/integrations/destinations/snowflake.md484| 1.0.5 | 2023-05-31 | [\#25782](https://github.com/airbytehq/airbyte/pull/25782) | Internal scaffolding for fCODE
MEDIUMdocs/integrations/destinations/bigquery.md440| 1.5.2 | 2023-07-05 | [\#27936](https://github.com/airbytehq/airbyte/pull/27936) | Internal scaffolding change foCODE
MEDIUMdocs/integrations/destinations/bigquery.md443| 1.4.6 | 2023-06-28 | [\#27268](https://github.com/airbytehq/airbyte/pull/27268) | Internal scaffolding change foCODE
MEDIUMdocs/integrations/destinations/bigquery.md450| 1.3.4 | 2023-04-28 | [\#25588](https://github.com/airbytehq/airbyte/pull/25588) | Internal scaffolding change foCODE
MEDIUMdocs/integrations/destinations/bigquery.md452| 1.3.1 | 2023-04-20 | [\#25097](https://github.com/airbytehq/airbyte/pull/25097) | Internal scaffolding change foCODE
MEDIUM…/operator-guides/using-the-airflow-airbyte-operator.md6# Using the Airbyte Operator to orchestrate Airbyte OSSCOMMENT
MEDIUM…d_docs/version-1.7/understanding-airbyte/tech-stack.md47### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_COMMENT
MEDIUM…/operator-guides/using-the-airflow-airbyte-operator.md6# Using the Airbyte Operator to orchestrate Airbyte OSSCOMMENT
MEDIUM…d_docs/version-1.8/understanding-airbyte/tech-stack.md47### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_COMMENT
MEDIUM…/operator-guides/using-the-airflow-airbyte-operator.md6# Using the Airbyte Operator to orchestrate Airbyte OSSCOMMENT
MEDIUM…d_docs/version-1.6/understanding-airbyte/tech-stack.md47### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_COMMENT
MEDIUM…/operator-guides/using-the-airflow-airbyte-operator.md6# Using the Airbyte Operator to orchestrate Airbyte CoreCOMMENT
MEDIUM…d_docs/version-2.0/understanding-airbyte/tech-stack.md47### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_COMMENT
MEDIUM…/operator-guides/using-the-airflow-airbyte-operator.md6# Using the Airbyte Operator to orchestrate Airbyte CoreCOMMENT
MEDIUM…d_docs/version-2.1/understanding-airbyte/tech-stack.md47### _Why do we use_ [_Temporal_](https://temporal.io) _for orchestration?_COMMENT
Docstring Block Structure9 hits · 45 pts
SeverityFileLineSnippetContext
HIGH…-shopify/source_shopify/shopify_graphql/bulk/record.py345 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.py255 Removes key-value pairs with None values from specified nested dictionaries in a record. This transformation iSTRING
HIGH…ft-onedrive/source_microsoft_onedrive/stream_reader.py141 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.py69 Performs a GET request to a Box API endpoint using the provided Box client. This is an internal helper functioSTRING
HIGH…nectors/destination-deepset/destination_deepset/api.py94Upload file to deepset Cloud. Args: file (DeepsetCloudFile): The file to upload write_mSTRING
HIGH…onnectors/source-google-ads/source_google_ads/utils.py347 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.py242 Downloads a file from an S3 bucket to a specified local directory. Args: file (RemoteFile)STRING
HIGH…harepoint/source_microsoft_sharepoint/stream_reader.py170 Retrieves a list of all nested files under the specified object. Args: drive_id: The ID ofSTRING
HIGH…rosoft-sharepoint/source_microsoft_sharepoint/utils.py44 Executes a query with retry logic on encountering specific HTTP errors. This function attempts to execute `objSTRING
Synthetic Comment Markers9 hits · 45 pts
SeverityFileLineSnippetContext
HIGH…ases/base-normalization/dbt-project-template/README.md151. You can also change directory (`cd /tmp/dev_root/workspace/1/0/normalize` for example) to one of the workspace generaCODE
HIGHdocs/integrations/destinations/postgres.md268You may want to create objects that depend on the tables generated by Airbyte, such as views. If youCODE
HIGHdocs/integrations/sources/devin-ai.md77| [Sessions Insights](https://docs.devin.ai/api-reference/v3/sessions/organizations-sessions-insights) | Full Refresh | CODE
HIGHdocs/integrations/sources/devin-ai.md111| 0.2.0 | 2026-04-22 | [76475](https://github.com/airbytehq/airbyte/pull/76475) | Add `sessions_insights` stream for anaCODE
HIGHdocs/community/contributing-to-airbyte/writing-docs.md14If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communiCODE
HIGH…cs/version-1.7/contributing-to-airbyte/writing-docs.md14If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communiCODE
HIGH…cs/version-1.8/contributing-to-airbyte/writing-docs.md14If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communiCODE
HIGH…cs/version-1.6/contributing-to-airbyte/writing-docs.md14If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communiCODE
HIGH…cs/version-2.0/contributing-to-airbyte/writing-docs.md14If you're interested in becoming a regular contributor, join Airbyte's [Contributor program](https://airbyte.com/communiCODE
AI Response Leakage2 hits · 15 pts
SeverityFileLineSnippetContext
HIGH…e-integrations/connectors/source-klaviyo/manifest.yaml4593# 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.yml97 # In this example, Nessie is configured with 3 clients and 3 rules:COMMENT
AI Structural Patterns14 hits · 14 pts
SeverityFileLineSnippetContext
LOW…rce-shopify/unit_tests/integration/test_bulk_stream.py206CODE
LOW…rce-shopify/unit_tests/integration/test_bulk_stream.py405CODE
LOW…rce-shopify/unit_tests/integration/test_bulk_stream.py410CODE
LOW…source-google-directory/source_google_directory/api.py75CODE
LOW…ions/connectors/source-youtube-analytics/components.py63CODE
LOW…/connectors/source-mixpanel/source_mixpanel/streams.py71CODE
LOW…/connectors/source-amazon-seller-partner/components.py638CODE
LOW…-integrations/connectors/source-bing-ads/components.py601CODE
LOW…aws-datalake/destination_aws_datalake/config_reader.py80CODE
LOW…/source-pinterest/unit_tests/test_config_migrations.py62CODE
LOW…rch-console/unit_tests/mock_server/response_builder.py122CODE
LOW…rce_facebook_marketing/streams/base_insight_streams.py74CODE
LOW…tion/transform_catalog/destination_name_transformer.py307CODE
LOW…tion/transform_catalog/destination_name_transformer.py312CODE
Example Usage Blocks6 hits · 9 pts
SeverityFileLineSnippetContext
LOWtools/bin/bulk-cdk/get-certified-connectors.sh9# Usage:COMMENT
LOWpoe-tasks/repo-root-tasks.toml6# Example usage:COMMENT
LOWpoe-tasks/repo-root-tasks.toml15# Example usage:COMMENT
LOWpoe-tasks/gradle-connector-tasks.toml15# Example usage:COMMENT
LOWdocs/check-docs-git-diff.sh12# Usage:COMMENT
LOW…ub/workflows/publish-connectors-prerelease-command.yml10# Usage:COMMENT
Slop Phrases3 hits · 6 pts
SeverityFileLineSnippetContext
MEDIUM…ogle-analytics-v4/source_google_analytics_v4/spec.json107 "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.json67 "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.py48 # Instead, the connector will make sure to push the first batch of data as a "replace" action: this will cauCOMMENT
Cross-Language Confusion (JS/TS)1 hit · 5 pts
SeverityFileLineSnippetContext
HIGHdocusaurus/src/components/PyAirbyteExample.jsx42 print(record)`}{" "}CODE
Dead Code1 hit · 2 pts
SeverityFileLineSnippetContext
MEDIUM…ectors/source-google-ads/unit_tests/test_components.py753CODE
TODO Padding1 hit · 2 pts
SeverityFileLineSnippetContext
LOW…/source/postgres/PostgresSourceJdbcPartitionFactory.kt499 // TODO: implement split for cursor incremental partitionCOMMENT