Repository Analysis

apache/airflow

Apache Airflow - A platform to programmatically author, schedule, and monitor workflows

24.3 Moderate AI signal View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of apache/airflow, a Python project with 46,629 GitHub stars. SynthScan v2.0 examined 2,121,659 lines of code across 10558 source files, recording 46250 pattern matches distributed across 25 syntactic categories. The overall adjusted score of 24.3 places this repository in the Moderate AI signal 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).

24.3
Adjusted Score
24.3
Raw Score
100%
Time Factor
2026-08-28
Last Push
46.6K
Stars
Python
Language
2.1M
Lines of Code
10.6K
Files
46.2K
Pattern Hits
2026-08-29
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 277HIGH 762MEDIUM 1087LOW 44124

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 46250 distinct pattern matches across 25 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.

Hyper-Verbose Identifiers25075 hits · 22948 pts
SeverityFileLineSnippetContext
LOWclients/python/README.md297def get_airflow_client_access_token(CODE
LOW…/java-test-bundle/src/resources/dags/java_test_dags.py25def missing_no_arg_constructor(): ...CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py97def _copy_elasticsearch_files(tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py123def _setup_elasticsearch_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py138def _setup_opensearch_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py169def _write_providers_mount_override(tmp_dir: Path, providers: list[str]) -> list[str]:CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py197def _setup_event_driven_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py246def _setup_xcom_object_storage_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py371def _setup_java_sdk_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py583def _pack_go_sdk_example_bundle(*, native=False):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py597def _setup_go_sdk_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py651def _setup_openlineage_integration(dot_env_file, tmp_dir, compose_file_names):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py670def _build_ts_sdk_example_bundle(*, native=False):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py715def _setup_ts_sdk_integration(dot_env_file, tmp_dir):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py756def spin_up_airflow_environment(tmp_path_factory: pytest.TempPathFactory):CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py872def pytest_runtest_makereport(item, call):CODE
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py112 def test_remote_logging_error_detail(self):CODE
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py46def create_request_session_with_retries(status_forcelist: list[int]):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py74def _wait_for_task_log_record(CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py109 def test_java_tasks_execute_successfully(self, dag_id: str):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py144 def test_transform_xcom_is_numeric_timestamp(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py172 def test_concurrent_client_calls_succeed(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py197 def test_numeric_xcom_casting(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py223 def test_load_retried_then_succeeded(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py257 def test_application_logs_preserve_their_level(self):CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py329 def test_uninstantiable_task_fails_with_actionable_error(self, task_id: str, expected_task_class: str):CODE
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py56def pull_value_from_bash_push(ti=None):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py90def test_upstream_xcoms_keep_their_shapes(completed_run: _CompletedRun):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py101def test_via_flat_args_summary_reflects_bound_arguments(completed_run: _CompletedRun):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py117def test_via_struct_no_tags_reflects_bound_arguments(completed_run: _CompletedRun):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py129def test_via_struct_arg_tag_reflects_bound_arguments(completed_run: _CompletedRun):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py140def test_via_struct_unmatched_arg_reflects_zero_valued_field(completed_run: _CompletedRun):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py153def test_via_flat_map_decodes_single_dict_whole(completed_run: _CompletedRun):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py159def test_via_struct_map_binds_single_dict_onto_map_field(completed_run: _CompletedRun):CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py167def test_via_plain_map_decodes_dict_into_a_typed_map(completed_run: _CompletedRun):CODE
LOW…_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py77def test_concurrent_faster_than_sequential(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py161def test_load_retried_then_succeeded(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py187def test_extract_xcom_has_go_version_and_int_timestamp(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py203def test_xcom_crosses_go_to_python(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py208def test_extract_logs_show_beep_loop(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py216def test_extract_logs_show_runtime_context(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py259def test_transform_logs_show_variable_read(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_dag.py109def test_build_message_xcom_round_trip(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_dag.py122def test_read_connection_xcom(completed_run: _CompletedRun):CODE
LOW…ests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_dag.py133def test_coordinator_logs_reach_task_log_store(completed_run: _CompletedRun):CODE
LOW…ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py62def test_all_openlineage_dags_succeed(compose_instance, airflow_dags_path, airflow_logs_path):CODE
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py56def discover_expected_dag_ids(dags_folder: Path) -> set[str]:CODE
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py122 def wait_for_dag_run_to_complete(self, dag_id: str, run_id: str, timeout: int = 300) -> str:CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py52 def _wait_for_kafka_consumer_group(self, compose_instance, timeout: int = 60, check_interval: int = 3):CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py73 def _wait_for_consumer_dag_runs(CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py138 def test_producer_triggers_consumer_and_kafka_offsets(self, compose_instance):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py58 def test_integration_run_dag_task_mapping(self):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py82 def test_integration_run_dag_with_scheduler_failure(self):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py112 def test_pod_failure_logging_with_container_terminated(self, mock_log):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py173 def test_pod_failure_logging_exception_handling(self, mock_log):CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py209 def test_pod_failure_logging_non_failed_state(self, mock_log):CODE
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py27def initialize_providers_manager():CODE
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py44def create_connection_without_db(monkeypatch):CODE
LOW…s-tests/tests/kubernetes_tests/test_other_executors.py52 def test_integration_run_dag_with_scheduler_failure(self):CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py180 def test_do_xcom_push_defaults_false(self, kubeconfig_path, tmp_path):CODE
25015 more matches not shown…
Over-Commented Block8604 hits · 8390 pts
SeverityFileLineSnippetContext
LOW.asf.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.asf.yaml81COMMENT
LOWcodecov.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.hadolint.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWpyproject.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWpyproject.toml1381 "apache-airflow-shared-serialization",COMMENT
LOW.readthedocs.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.gitpod.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWyamllint-config.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.markdownlint.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW.cherry_picker.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWclients/python/pyproject.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWclients/python/test_python_client.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWclients/python/test_python_client.py41except ImportError:COMMENT
LOWairflow-e2e-tests/.pre-commit-config.yaml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/pyproject.toml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/kafka.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/openlineage-compat-db.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/go.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/localstack.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/Dockerfile.java1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/java.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/openlineage.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/openlineage.yml21# openlineage_tests/prepare_dags.py (conftest._setup_openlineage_integration). They emit through theCOMMENT
LOWairflow-e2e-tests/docker/openlineage.yml41 AIRFLOW__OPENLINEAGE__EXECUTION_TIMEOUT: '60'COMMENT
LOWairflow-e2e-tests/docker/opensearch.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/elasticsearch.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/ts.yml1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/docker/kafka/update_run.sh1#!/bin/shCOMMENT
LOW…/java-test-bundle/src/resources/dags/java_test_dags.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py381COMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/constants.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOWairflow-e2e-tests/tests/airflow_e2e_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…sts/tests/airflow_e2e_tests/e2e_test_utils/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…sts/tests/airflow_e2e_tests/java_sdk_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py41# "extra": {COMMENT
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…asticsearch_tests/test_remote_logging_elasticsearch.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…w_e2e_tests/remote_log_elasticsearch_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…tests/tests/airflow_e2e_tests/go_sdk_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ject_storage_tests/test_xcom_object_storage_backend.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…irflow_e2e_tests/xcom_object_storage_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/remote_log_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…flow_e2e_tests/remote_log_tests/test_remote_logging.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…tests/tests/airflow_e2e_tests/ts_sdk_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_dag.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…tests/airflow_e2e_tests/openlineage_tests/task_logs.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
LOW…/tests/airflow_e2e_tests/openlineage_tests/__init__.py1# Licensed to the Apache Software Foundation (ASF) under oneCOMMENT
8544 more matches not shown…
Unused Imports6337 hits · 6021 pts
SeverityFileLineSnippetContext
LOWclients/python/test_python_client.py27CODE
LOW…/java-test-bundle/src/resources/dags/java_test_dags.py19CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py17CODE
LOWairflow-e2e-tests/tests/airflow_e2e_tests/constants.py17CODE
LOW…2e_tests/e2e_test_utils/base_remote_log_search_test.py17CODE
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py17CODE
LOW…/airflow_e2e_tests/java_sdk_tests/test_java_sdk_dag.py55CODE
LOW…s/tests/airflow_e2e_tests/dags/example_event_driven.py18CODE
LOW…ests/tests/airflow_e2e_tests/dags/example_xcom_test.py19CODE
LOW…asticsearch_tests/test_remote_logging_elasticsearch.py17CODE
LOW…e2e_tests/go_sdk_tests/test_go_sdk_taskflow_binding.py27CODE
LOW…_e2e_tests/go_sdk_tests/test_go_sdk_concurrent_xcom.py24CODE
LOW…ests/airflow_e2e_tests/go_sdk_tests/test_go_sdk_dag.py66CODE
LOW…ject_storage_tests/test_xcom_object_storage_backend.py17CODE
LOW…flow_e2e_tests/remote_log_tests/test_remote_logging.py17CODE
LOW…ests/airflow_e2e_tests/ts_sdk_tests/test_ts_sdk_dag.py34CODE
LOW…ow_e2e_tests/openlineage_tests/test_openlineage_e2e.py17CODE
LOW…s/tests/airflow_e2e_tests/openlineage_tests/harness.py26CODE
LOW…ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py31CODE
LOW…tests/airflow_e2e_tests/openlineage_tests/task_logs.py26CODE
LOW…openlineage_tests/dags_extra/openlineage_warmup_dag.py24CODE
LOW…s/openlineage_tests/dags_extra/e2e_versioned_bundle.py31CODE
LOW…flow_e2e_tests/event_driven_tests/test_event_driven.py24CODE
LOW…log_opensearch_tests/test_remote_logging_opensearch.py17CODE
LOW…sts/airflow_e2e_tests/basic_tests/test_example_dags.py18CODE
LOW…low_e2e_tests/basic_tests/test_basic_dag_operations.py17CODE
LOWts-sdk/example/dags/typescript_example.py18CODE
LOWts-sdk/scripts/ci/prek/ts_sdk_lint.py18CODE
LOWts-sdk/scripts/ci/prek/check_supervisor_schema.py18CODE
LOWts-sdk/scripts/ci/prek/compile_ts_sdk.py18CODE
LOWts-sdk/scripts/ci/prek/verify_ts_sdk_package.py18CODE
LOWkubernetes-tests/lang_sdk/stage_artifacts.py41CODE
LOWkubernetes-tests/lang_sdk/dags/lang_sdk_combined.py37CODE
LOW…sts/tests/kubernetes_tests/test_kubernetes_executor.py17CODE
LOWkubernetes-tests/tests/kubernetes_tests/conftest.py17CODE
LOW…s-tests/tests/kubernetes_tests/test_other_executors.py17CODE
LOW…tests/kubernetes_tests/test_kubernetes_pod_operator.py17CODE
LOW…kubernetes_tests/test_lang_sdk_coordinator_executor.py30CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py17CODE
LOWairflow-ctl/tests/conftest.py18CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py18CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_client.py18CODE
LOW…w-ctl/tests/airflow_ctl/ctl/test_console_formatting.py17CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py18CODE
LOW…ests/airflow_ctl/ctl/commands/test_variable_command.py17CODE
LOW…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py19CODE
LOW…s/airflow_ctl/ctl/commands/test_connections_command.py17CODE
LOW…/tests/airflow_ctl/ctl/commands/test_config_command.py17CODE
LOW…tests/airflow_ctl/ctl/commands/test_version_command.py17CODE
LOW…ctl/tests/airflow_ctl/ctl/commands/test_dag_command.py17CODE
LOW…tl/tests/airflow_ctl/ctl/commands/test_jobs_command.py17CODE
LOW…tl/tests/airflow_ctl/ctl/commands/test_task_command.py17CODE
LOW…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py17CODE
LOWairflow-ctl/docs/conf.py21CODE
LOW…iagrams/airflowctl_api_network_architecture_diagram.py17CODE
LOWairflow-ctl/src/airflowctl/__init__.py18CODE
LOWairflow-ctl/src/airflowctl/exceptions.py22CODE
LOWairflow-ctl/src/airflowctl/__main__.py22CODE
LOWairflow-ctl/src/airflowctl/utils/helpers.py18CODE
LOWairflow-ctl/src/airflowctl/utils/module_loading.py18CODE
6277 more matches not shown…
Cross-File Repetition614 hits · 3070 pts
SeverityFileLineSnippetContext
HIGHairflow-ctl/src/airflowctl/utils/helpers.py0use a predicate to partition entries into false entries and true entriesSTRING
HIGHairflow-core/src/airflow/utils/helpers.py0use a predicate to partition entries into false entries and true entriesSTRING
HIGHdevel-common/src/docs/build_docs.py0use a predicate to partition entries into false entries and true entriesSTRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so pleSTRING
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so pleSTRING
HIGHairflow-core/src/airflow/utils/state.py0all possible states that a dagrun can be in. these are "shared" with taskinstancestate in some parts of the code, so pleSTRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wiSTRING
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wiSTRING
HIGHairflow-core/src/airflow/utils/state.py0all possible states that a task instance can be in. note that none is also allowed, so always use this in a type hint wiSTRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0request body for setting an asset state store value.STRING
HIGHtask-sdk/src/airflow/sdk/api/datamodels/_generated.py0request body for setting an asset state store value.STRING
HIGH…_fastapi/execution_api/datamodels/asset_state_store.py0request body for setting an asset state store value.STRING
HIGH…w/api_fastapi/core_api/datamodels/asset_state_store.py0request body for setting an asset state store value.STRING
HIGHairflow-ctl/src/airflowctl/api/datamodels/generated.py0task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of aSTRING
HIGH…src/airflow/api_fastapi/core_api/datamodels/dag_run.py0task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of aSTRING
HIGH…flow/api_fastapi/core_api/datamodels/task_instances.py0task instance collection response supporting both offset and cursor pagination. a single flat model is used instead of aSTRING
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly STRING
HIGHairflow-core/src/airflow/utils/yaml.py0use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly STRING
HIGHtask-sdk/src/airflow/sdk/yaml.py0use libyaml for yaml dump/load operations where possible. if libyaml is available we will use it -- it is significantly STRING
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.STRING
HIGHtask-sdk/src/airflow/sdk/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.STRING
HIGHairflow-core/src/airflow/utils/yaml.py0like yaml.safe_load, but use the c libyaml for speed where we can.STRING
HIGHairflow-ctl/src/airflowctl/ctl/utils/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.STRING
HIGHtask-sdk/src/airflow/sdk/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.STRING
HIGHairflow-core/src/airflow/utils/yaml.py0like yaml.safe_dump, but use the c libyaml for speed where we can.STRING
HIGHtask-sdk/tests/task_sdk/bases/test_operator.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGH…elery/tests/integration/celery/test_celery_executor.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGH…ore/tests/unit/serialization/test_dag_serialization.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGHairflow-core/tests/unit/models/test_renderedtifields.py0class for testing purpose: allows to create objects with custom attributes in one single statement.STRING
HIGHtask-sdk/tests/task_sdk/definitions/test_callback.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGH…re/tests/unit/serialization/test_serialized_objects.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_dag.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_deadline.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_serialized_dag.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHairflow-core/tests/unit/models/test_dagrun.py0used in a number of tests to confirm that deadlines and deadlinealerts function correctly.STRING
HIGHtask-sdk/src/airflow/sdk/bases/notifier.py0template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :parSTRING
HIGHtask-sdk/src/airflow/sdk/bases/operator.py0template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :parSTRING
HIGHairflow-core/src/airflow/triggers/base.py0template all attributes listed in *self.template_fields*. this mutates the attributes in-place and is irreversible. :parSTRING
HIGHtask-sdk/src/airflow/sdk/bases/hook.py0return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbapSTRING
HIGH…/sql/src/airflow/providers/common/sql/operators/sql.py0return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbapSTRING
HIGH…low/providers/common/sql/operators/generic_transfer.py0return dbapihook for this connection id. :param conn_id: connection id :param hook_params: hook parameters :return: dbapSTRING
HIGHtask-sdk/src/airflow/sdk/execution_time/task_runner.py0get the previous dag run before the given logical date, optionally filtered by state.STRING
HIGHtask-sdk/src/airflow/sdk/api/client.py0get the previous dag run before the given logical date, optionally filtered by state.STRING
HIGH…c/airflow/api_fastapi/execution_api/routes/dag_runs.py0get the previous dag run before the given logical date, optionally filtered by state.STRING
HIGHtask-sdk/src/airflow/sdk/definitions/deadline.py0a deadline that calculates the average runtime from past dag runs.STRING
HIGH…core/src/airflow/serialization/definitions/deadline.py0a deadline that calculates the average runtime from past dag runs.STRING
HIGHairflow-core/src/airflow/models/deadline.py0a deadline that calculates the average runtime from past dag runs.STRING
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:STRING
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:STRING
HIGH…/src/airflow/serialization/definitions/baseoperator.py0return mapped task groups this task belongs to. groups are returned from the innermost to the outmost. :meta private:STRING
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:STRING
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:STRING
HIGH…/src/airflow/serialization/definitions/baseoperator.py0get the mapped task group "closest" to this task in the dag. :meta private:STRING
HIGH…/airflow/sdk/definitions/_internal/abstractoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:STRING
HIGH…rc/airflow/serialization/definitions/mappedoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:STRING
HIGH…/src/airflow/serialization/definitions/baseoperator.py0return true if the task is mappedoperator or is in a mapped task group. :meta private:STRING
HIGHtask-sdk/src/airflow/sdk/serde/__init__.py0return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster thanSTRING
HIGHtask-sdk/src/airflow/sdk/serde/typing.py0return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster thanSTRING
HIGHairflow-core/src/airflow/serialization/typing.py0return true if the class is a pydantic.main.basemodel. checking is done by attributes as it is significantly faster thanSTRING
HIGHproviders/ftp/src/airflow/providers/ftp/assets/ftp.py0translate asset with valid aip-60 uri to openlineage with assistance from the hook.STRING
554 more matches not shown…
Hallucination Indicators277 hits · 2880 pts
SeverityFileLineSnippetContext
CRITICALairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py269# This mirrors org.apache.spark.launcher.JavaModuleOptions.defaultModuleOptions()COMMENT
CRITICALairflow-ctl/src/airflowctl/ctl/cli_parser.py45from airflowctl.utils.helpers import partitionCODE
CRITICAL…tableau/src/airflow/providers/tableau/hooks/tableau.py25from airflow.utils.helpers import exactly_oneCODE
CRITICAL…unit/amazon/aws/triggers/test_opensearch_serverless.py29from airflow.utils.helpers import prune_dictCODE
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py71 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(CODE
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py101 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(CODE
CRITICAL…sts/unit/amazon/aws/transfers/test_hive_to_dynamodb.py140 operator = airflow.providers.amazon.aws.transfers.hive_to_dynamodb.HiveToDynamoDBOperator(CODE
CRITICAL…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py56from airflow.utils.helpers import convert_camel_to_snakeCODE
CRITICAL…unit/amazon/aws/executors/batch/test_batch_executor.py47from airflow.utils.helpers import convert_camel_to_snakeCODE
CRITICAL…ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py182 mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params)CODE
CRITICAL…ders/amazon/tests/unit/amazon/aws/hooks/test_athena.py201 mock_conn.return_value.get_paginator.return_value.paginate.assert_called_with(**expected_call_params)CODE
CRITICAL…oviders/amazon/tests/unit/amazon/aws/hooks/test_dms.py452 mock_conn.return_value.get_waiter.return_value.wait.assert_called_with(**expected_waiter_call_params)CODE
CRITICAL…oviders/amazon/tests/unit/amazon/aws/hooks/test_eks.py100 from moto.core.exceptions import AWSErrorCODE
CRITICAL…rs/amazon/tests/unit/amazon/aws/hooks/test_base_aws.py446 user_agent_dict = dict(tag.split("/") for tag in executor.ecs.meta.config.user_agent.split(" "))CODE
CRITICAL…unit/amazon/aws/hooks/test_sagemaker_unified_studio.py113 self.hook._sagemaker_studio.execution_client.start_execution.assert_called_once()CODE
CRITICAL…unit/amazon/aws/hooks/test_sagemaker_unified_studio.py124 self.hook._sagemaker_studio.execution_client.get_execution.assert_called()CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py356 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py411 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py454 hook.get_conn.return_value.get_paginator.return_value.paginate.assert_called_with(CODE
CRITICALproviders/amazon/tests/unit/amazon/aws/hooks/test_s3.py511 hook.resource.Object.return_value.load.assert_called_with(CODE
CRITICAL…/tests/unit/amazon/aws/auth_manager/avp/test_facade.py30from airflow.utils.helpers import prune_dictCODE
CRITICALproviders/amazon/tests/system/amazon/aws/utils/k8s.py19from airflow.utils.helpers import exactly_oneCODE
CRITICAL…/providers/amazon/aws/sensors/opensearch_serverless.py29from airflow.utils.helpers import exactly_oneCODE
CRITICAL…c/airflow/providers/amazon/aws/operators/s3_vectors.py27from airflow.utils.helpers import prune_dictCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/rds.py38from airflow.utils.helpers import prune_dictCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/emr.py68from airflow.utils.helpers import exactly_one, prune_dictCODE
CRITICAL…low/providers/amazon/aws/operators/redshift_cluster.py40from airflow.utils.helpers import prune_dictCODE
CRITICAL…airflow/providers/amazon/aws/operators/glue_catalog.py28from airflow.utils.helpers import prune_dictCODE
CRITICAL…/airflow/providers/amazon/aws/operators/eventbridge.py26from airflow.utils.helpers import prune_dictCODE
CRITICAL…flow/providers/amazon/aws/operators/mwaa_serverless.py28from airflow.utils.helpers import prune_dictCODE
CRITICAL…rc/airflow/providers/amazon/aws/operators/sagemaker.py50from airflow.utils.helpers import prune_dictCODE
CRITICAL…roviders/amazon/aws/operators/opensearch_serverless.py29from airflow.utils.helpers import prune_dictCODE
CRITICAL…rc/airflow/providers/amazon/aws/operators/s3_tables.py31from airflow.utils.helpers import prune_dictCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/ecr.py25from airflow.utils.helpers import prune_dictCODE
CRITICAL…mazon/src/airflow/providers/amazon/aws/operators/s3.py35from airflow.utils.helpers import exactly_oneCODE
CRITICAL…/src/airflow/providers/amazon/aws/operators/bedrock.py47from airflow.utils.helpers import prune_dictCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/operators/ecs.py43from airflow.utils.helpers import prune_dictCODE
CRITICAL…providers/amazon/aws/triggers/opensearch_serverless.py23from airflow.utils.helpers import exactly_oneCODE
CRITICAL…azon/src/airflow/providers/amazon/aws/triggers/base.py27from airflow.utils.helpers import prune_dictCODE
CRITICAL…zon/src/airflow/providers/amazon/aws/utils/__init__.py31from airflow.utils.helpers import prune_dictCODE
CRITICAL…rflow/providers/amazon/aws/transfers/dynamodb_to_s3.py36from airflow.utils.helpers import prune_dictCODE
CRITICAL…viders/amazon/aws/executors/ecs/ecs_executor_config.py46from airflow.utils.helpers import prune_dictCODE
CRITICAL…low/providers/amazon/aws/executors/ecs/ecs_executor.py53from airflow.utils.helpers import merge_dicts, prune_dictCODE
CRITICAL…providers/amazon/aws/executors/batch/batch_executor.py38from airflow.utils.helpers import merge_dicts, prune_dictCODE
CRITICAL…rs/amazon/aws/executors/batch/batch_executor_config.py42from airflow.utils.helpers import prune_dictCODE
CRITICAL…ers/amazon/aws/executors/aws_lambda/lambda_executor.py47from airflow.utils.helpers import prune_dictCODE
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/links/emr.py26from airflow.utils.helpers import exactly_oneCODE
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/hooks/sqs.py23from airflow.utils.helpers import prune_dictCODE
CRITICAL…/src/airflow/providers/amazon/aws/hooks/eventbridge.py22from airflow.utils.helpers import prune_dictCODE
CRITICAL…/amazon/src/airflow/providers/amazon/aws/hooks/logs.py27from airflow.utils.helpers import prune_dictCODE
CRITICAL…zon/src/airflow/providers/amazon/aws/hooks/base_aws.py60from airflow.utils.helpers import exactly_oneCODE
CRITICAL…rs/amazon/src/airflow/providers/amazon/aws/hooks/s3.py66from airflow.utils.helpers import chunksCODE
CRITICAL…s/amazon/src/airflow/providers/amazon/aws/hooks/sns.py25from airflow.utils.helpers import prune_dictCODE
CRITICAL…irflow/providers/amazon/aws/auth_manager/avp/facade.py34from airflow.utils.helpers import prune_dictCODE
CRITICAL…/src/airflow/providers/amazon/aws/notifications/ses.py26from airflow.utils.helpers import prune_dictCODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py176 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py207 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py288 mock_client.secrets.kv.v2.read_secret_version.assert_not_called()CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py368 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(CODE
CRITICAL…s/hashicorp/tests/unit/hashicorp/secrets/test_vault.py398 mock_client.secrets.kv.v2.read_secret_version.assert_has_calls(CODE
217 more matches not shown…
Decorative Section Separators634 hits · 2130 pts
SeverityFileLineSnippetContext
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py64# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py66# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py170# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py172# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py226# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py228# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py249# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py251# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py268# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py270# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py336# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py338# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py41# ---------------------------------------------------------------------------COMMENT
MEDIUM…sk-sdk/tests/task_sdk/definitions/test_retry_policy.py43# ---------------------------------------------------------------------------COMMENT
MEDIUM…low/providers/amazon/aws/executors/ecs/ecs_executor.py682 # ── Back-compat shims for renamed methods/attrs ────────────────────────COMMENT
MEDIUM…ders/google/tests/unit/google/cloud/links/test_base.py24# ---------------------------------------------------------------------------COMMENT
MEDIUM…ders/google/tests/unit/google/cloud/links/test_base.py26# ---------------------------------------------------------------------------COMMENT
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py2024 # -------------------------------------------------------------------------COMMENT
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py2026 # -------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py24# --------------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py26# --------------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py34# --------------------------------------------------------------------------------COMMENT
MEDIUM…ft/winrm/tests/system/microsoft/winrm/example_winrm.py37# --------------------------------------------------------------------------------COMMENT
MEDIUM…azure/tests/unit/microsoft/azure/hooks/test_compute.py206 # ------------------------------------------------------------------COMMENT
MEDIUM…azure/tests/unit/microsoft/azure/hooks/test_compute.py208 # ------------------------------------------------------------------COMMENT
MEDIUM…src/airflow/providers/microsoft/azure/hooks/compute.py172 # ------------------------------------------------------------------COMMENT
MEDIUM…src/airflow/providers/microsoft/azure/hooks/compute.py174 # ------------------------------------------------------------------COMMENT
MEDIUM…viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py50 # ------------------------------------------------------------------COMMENT
MEDIUM…viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py52 # ------------------------------------------------------------------COMMENT
MEDIUM…viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py118 # ------------------------------------------------------------------COMMENT
MEDIUM…viders/ibm/db2/tests/unit/ibm/db2/dialects/test_db2.py120 # ------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py45# ----------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py47# ----------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py72# ----------------------------------------------------------------------COMMENT
MEDIUM…compat/tests/unit/common/compat/sqlalchemy/test_orm.py74# ----------------------------------------------------------------------COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py149 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py151 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py153 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py155 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py163 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py165 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py169 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py171 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py173 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py175 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py186 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py188 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py198 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py200 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py204 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py206 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py208 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py210 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py212 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py214 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py218 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py220 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py224 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py226 # ============================================================================COMMENT
MEDIUM…mmon/compat/src/airflow/providers/common/compat/sdk.py229 # ============================================================================COMMENT
574 more matches not shown…
Excessive Try-Catch Wrapping1159 hits · 1219 pts
SeverityFileLineSnippetContext
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py842 except Exception:CODE
LOW…ject_storage_tests/test_xcom_object_storage_backend.py65 except Exception as e:CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py163 except Exception:CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py198 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py85 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py119 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py183 except Exception as e:CODE
LOW…-ctl/src/airflowctl/ctl/commands/connection_command.py46 except Exception as e:CODE
LOW…-ctl/src/airflowctl/ctl/commands/connection_command.py73 except Exception as e:CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/pool_command.py82 except Exception as e:CODE
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py833 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py251 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py258 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py288 except Exception as e:CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/conftest.py340 except Exception:CODE
LOW…_sdk/execution_time/test_connection_test_supervisor.py244 except Exception as e:CODE
MEDIUM…_sdk/execution_time/test_connection_test_supervisor.py241def capture():CODE
LOW…k-sdk/tests/task_sdk/execution_time/test_supervisor.py1496 except Exception as e:CODE
LOWtask-sdk/tests/task_sdk/execution_time/test_comms.py166 except Exception as e:CODE
MEDIUMtask-sdk/tests/task_sdk/execution_time/test_comms.py162def send_and_store(idx):CODE
LOWtask-sdk/src/airflow/sdk/configuration.py159 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/log.py241 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py106 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py593 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/plugins_manager.py94 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/lineage.py203 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/timezone.py38except Exception:CODE
LOWtask-sdk/src/airflow/sdk/io/path.py161 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/bases/sensor.py220 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/bases/notifier.py139 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/bases/notifier.py153 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/comms.py374 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py303 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py394 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py469 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py481 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py951 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py985 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1256 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1454 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1582 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1601 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1706 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2410 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2562 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2345 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2355 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2363 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2371 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2381 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2388 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1212 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1440 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1452 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1593 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1713 except Exception as e:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1731 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1820 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1846 except Exception:CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2074 except Exception:CODE
1099 more matches not shown…
Self-Referential Comments283 hits · 857 pts
SeverityFileLineSnippetContext
MEDIUMclients/python/test_python_client.py108 # Create a DAGRun object (no dag_id should be specified because it is read-only property of DAGRun)COMMENT
MEDIUM…s/tests/airflow_e2e_tests/dags/example_event_driven.py107# Define a trigger that listens to an external message queue (Apache Kafka in this case)COMMENT
MEDIUM…s/tests/airflow_e2e_tests/dags/example_event_driven.py118# Define an asset that watches for messages on the queueCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py119 # Create a mock KubernetesExecutor instanceCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py136 # Create a test task keyCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py179 # Create a mock KubernetesExecutor instanceCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py183 # Create a test task keyCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py215 # Create a mock KubernetesExecutor instanceCOMMENT
MEDIUM…sts/tests/kubernetes_tests/test_kubernetes_executor.py220 # Create a test task keyCOMMENT
MEDIUMairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py233 # Create a temporary fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py146 # Create a proper pool object with dictionary attributes instead of MagicMockCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_pool_command.py159 # Create a mock response with proper dictionary attributesCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py341 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py358 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py375 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py394 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py411 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py428 # Create a corrupted config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py442 # Create a config fileCOMMENT
MEDIUM…tl/tests/airflow_ctl/ctl/commands/test_auth_command.py293 # Create a config fileCOMMENT
MEDIUMtask-sdk/tests/task_sdk/test_lineage.py722 # Create a large valueCOMMENT
MEDIUMtask-sdk/tests/task_sdk/test_lineage.py778 # Create a non-serializable objectCOMMENT
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py844 # Create a directory that existsCOMMENT
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py848 # Create a mock bundle instanceCOMMENT
MEDIUM…-sdk/tests/task_sdk/execution_time/test_task_runner.py866 # Create a directory with read permissionsCOMMENT
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py780 # Create a mock client to assert calls to the clientCOMMENT
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py1235 # Create a fake placeholder in the open socket weakrefCOMMENT
MEDIUM…k-sdk/tests/task_sdk/execution_time/test_supervisor.py3809 # Create a simple TaskInstance datamodel to pass to the supervisorCOMMENT
MEDIUMtask-sdk/tests/task_sdk/definitions/test_dag.py334 # Create a linear chain: t1 -> t2 -> t3 -> t4 -> t5COMMENT
MEDIUMtask-sdk/tests/task_sdk/definitions/test_dag.py369 # Create a diamond pattern:COMMENT
MEDIUM…-sdk/tests/task_sdk/definitions/test_mappedoperator.py810 # Create a mapped task within the task groupCOMMENT
MEDIUMtask-sdk/dev/datamodel_code_formatter.py109 # Create a replacement for 'Tasks' -> 'tuple[str, int]'COMMENT
MEDIUMtask-sdk/src/airflow/sdk/execution_time/supervisor.py2157 # Create a socketpair preemptively, in case the task process runs VirtualEnv operator or run_as_userCOMMENT
MEDIUMtask-sdk/src/airflow/sdk/execution_time/supervisor.py2210 # Create a minimal supervisor instance for trigger executionCOMMENT
MEDIUM…sdk/src/airflow/sdk/execution_time/execute_workload.py66 # Create a mutually exclusive group to ensure that only one of the flags is setCOMMENT
MEDIUMtask-sdk/src/airflow/sdk/api/client.py315 # Create a deferred state payload from msgCOMMENT
MEDIUMtask-sdk/src/airflow/sdk/api/client.py327 # Create a reschedule state payload from msgCOMMENT
MEDIUMproviders-summary-docs/conf.py26# This file is execfile()d with the current directory set to itsCOMMENT
MEDIUM…ders/presto/tests/unit/presto/hooks/test_presto_sql.py149 # Create a real Airflow connectionCOMMENT
MEDIUM…it/amazon/aws/sensors/test_sagemaker_unified_studio.py91 # Create the sensorCOMMENT
MEDIUM…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1153 # Create a temporary credentials fileCOMMENT
MEDIUM…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1212 # Create a temporary credentials fileCOMMENT
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py141 # Create the operatorCOMMENT
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py189 # Create the operator with wait_for_completion set to TrueCOMMENT
MEDIUM…/amazon/aws/operators/test_sagemaker_unified_studio.py239 # Create the operator with wait_for_completion set to FalseCOMMENT
MEDIUM…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py173 # Create a test file remotelyCOMMENT
MEDIUM…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py182 # Create a new Collection and verify it is empty.COMMENT
MEDIUM…sts/unit/amazon/aws/executors/ecs/test_ecs_executor.py274 # Create a new Collection and add a two tasks.COMMENT
MEDIUM…mazon/aws/executors/aws_lambda/test_lambda_executor.py1211 # Create a team-specific executor.COMMENT
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py209 # Create the local log file structureCOMMENT
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py256 # Create a logger factory and pass in the file path we want it to useCOMMENT
MEDIUM…viders/amazon/tests/unit/amazon/aws/bundles/test_s3.py195 # Create a pytest Call object to compare against the call_args_list of the _log.debug mockCOMMENT
MEDIUM…ders/amazon/tests/system/amazon/aws/example_bedrock.py65# Creating a custom model takes nearly two hours. If SKIP_LONG_TASKSCOMMENT
MEDIUM…tests/system/amazon/aws/example_eks_with_nodegroups.py93 # Create an Amazon EKS Cluster control plane without attaching compute service.COMMENT
MEDIUM…ers/amazon/tests/system/amazon/aws/example_datasync.py184 # Create a task (the task does not exist)COMMENT
MEDIUM…/system/amazon/aws/example_eks_with_fargate_profile.py76 # Create an Amazon EKS Cluster control plane without attaching a compute service.COMMENT
MEDIUM…m/amazon/aws/example_eks_with_nodegroup_in_one_step.py91 # Create an Amazon EKS cluster control plane and an EKS nodegroup compute platform in one step.COMMENT
MEDIUMproviders/amazon/tests/system/amazon/aws/example_ec2.py62 # Creating the key takes a very short but measurable time, preventing race condition:COMMENT
MEDIUM…azon/tests/system/amazon/aws/example_dms_serverless.py154 # Create the Table.COMMENT
MEDIUM…azon/tests/system/amazon/aws/example_step_functions.py57 # Create a Step Functions State Machine and return the ARN for use byCOMMENT
223 more matches not shown…
Deep Nesting973 hits · 831 pts
SeverityFileLineSnippetContext
LOWairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py756CODE
LOWkubernetes-tests/tests/kubernetes_tests/test_base.py245CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py219CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py610CODE
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py842CODE
LOWairflow-ctl/src/airflowctl/api/client.py200CODE
LOWairflow-ctl/src/airflowctl/api/client.py251CODE
LOWairflow-ctl/src/airflowctl/api/operations.py170CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py989CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py532CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py739CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py832CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py836CODE
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py124CODE
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py729CODE
LOW…flow-ctl/src/airflowctl/ctl/commands/config_command.py105CODE
LOWtask-sdk/tests/conftest.py188CODE
LOW…k-sdk/tests/task_sdk/test_providers_manager_runtime.py182CODE
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py6074CODE
LOW…k-sdk/tests/task_sdk/execution_time/test_supervisor.py3865CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py218CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py567CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py993CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py1006CODE
LOWtask-sdk/tests/task_sdk/definitions/test_taskgroup.py1010CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py441CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py496CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py610CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py463CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py515CODE
LOW…-sdk/tests/task_sdk/definitions/test_mappedoperator.py650CODE
LOWtask-sdk/src/airflow/sdk/configuration.py211CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py251CODE
LOWtask-sdk/src/airflow/sdk/providers_manager_runtime.py305CODE
LOWtask-sdk/src/airflow/sdk/coordinators/_subprocess.py70CODE
LOWtask-sdk/src/airflow/sdk/coordinators/_subprocess.py157CODE
LOWtask-sdk/src/airflow/sdk/io/fs.py52CODE
LOWtask-sdk/src/airflow/sdk/bases/sensor.py183CODE
LOWtask-sdk/src/airflow/sdk/bases/resumablejobmixin.py103CODE
LOWtask-sdk/src/airflow/sdk/bases/decorator.py279CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py2005CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py681CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1065CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1188CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1532CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1752CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py979CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1384CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1397CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1533CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py1698CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2313CODE
LOWtask-sdk/src/airflow/sdk/execution_time/task_runner.py2408CODE
LOW…/src/airflow/sdk/execution_time/callback_supervisor.py349CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py1392CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py857CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py1241CODE
LOW…-sdk/src/airflow/sdk/execution_time/schema/__init__.py73CODE
LOWtask-sdk/src/airflow/sdk/definitions/mappedoperator.py117CODE
LOWtask-sdk/src/airflow/sdk/definitions/xcom_arg.py100CODE
913 more matches not shown…
Cross-Language Confusion133 hits · 756 pts
SeverityFileLineSnippetContext
HIGHairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py672 "pnpm install --frozen-lockfile && pnpm run build && cd example && pnpm install && pnpm run build"CODE
HIGH…tests/kubernetes_tests/test_kubernetes_pod_operator.py546 'echo "retrieved from mount" > /tmp/test_volume/test.txt && cat /tmp/test_volume/test.txt'CODE
HIGHtask-sdk/tests/task_sdk/api/test_client.py789 # Return None (null) when no previous TI foundCOMMENT
HIGHtask-sdk/tests/task_sdk/api/test_client.py1748 # Return None (null) when no previous Dag run foundCOMMENT
HIGHtask-sdk/tests/task_sdk/serde/test_serializers.py282 assert i.equals(d)CODE
HIGHtask-sdk/tests/task_sdk/serde/test_serializers.py301 assert i.equals(d)CODE
HIGHtask-sdk/src/airflow/sdk/bases/operator.py1533 DagContext.push(None)CODE
HIGHtask-sdk/src/airflow/sdk/definitions/dag.py756 DagContext.push(self)CODE
HIGHtask-sdk/src/airflow/sdk/definitions/taskgroup.py402 TaskGroupContext.push(self)CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py142 assert read_df.equals(test_df)CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py246 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py256 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py298 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py340 assert df.equals(CODE
HIGH…azon/tests/unit/amazon/aws/transfers/test_sql_to_s3.py350 assert df.equals(CODE
HIGH…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py602 '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}',STRING
HIGH…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py612 '{"datetime": "2023-01-01T00:00:00+00:00", "customObject": null}',STRING
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py59 if command -v yum &> /dev/null; thenCODE
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py61 elif command -v dnf &> /dev/null; thenCODE
HIGHproviders/amazon/tests/system/amazon/aws/example_ssm.py69 if ! command -v amazon-ssm-agent &> /dev/null; thenCODE
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py44 backend_kwargs = {"connections_prefix": "/airflow/connections", "profile_name": null}STRING
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py52 If set to None (null), requests for connections will not be sent to AWS SSM Parameter Store.STRING
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py58 If set to None (null), requests for variables will not be sent to AWS SSM Parameter Store.STRING
HIGH…irflow/providers/amazon/aws/secrets/systems_manager.py64 If set to None (null), requests for configurations will not be sent to AWS SSM Parameter Store.STRING
HIGH…mazon/src/airflow/providers/amazon/aws/hooks/athena.py258 self.log.error("Invalid Query state (null). Query execution id: %s", query_execution_id)CODE
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py94 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py52 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py66 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…s/teradata/tests/unit/teradata/utils/test_bteq_util.py80 ssh_client.exec_command.assert_called_once_with("uname || ver")CODE
HIGH…data/src/airflow/providers/teradata/utils/bteq_util.py32 stdin, stdout, stderr = ssh_client.exec_command("uname || ver")CODE
HIGH…adata/src/airflow/providers/teradata/utils/tpt_util.py134 f"count=$(($(stat -c '%s' {shlex.quote(file_path)})/4096+1)) 2>/dev/null; "CODE
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py55 (default: 'connections'). If set to None (null), requests for connections will not be sent to Vault.STRING
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py58 (default: 'variables'). If set to None (null), requests for variables will not be sent to Vault.STRING
HIGH…icorp/src/airflow/providers/hashicorp/secrets/vault.py61 (default: 'config'). If set to None (null), requests for configurations will not be sent to Vault.STRING
HIGH…ts/unit/google/cloud/transfers/test_postgres_to_gcs.py44 b'{"some_json": {"firtname": "John", "lastname": "Smith", "nested_dict": {"a": null, "b": "something"}}, "some_num":CODE
HIGH…ts/unit/google/cloud/transfers/test_postgres_to_gcs.py73 "nested_dict": {"a": null, "b": "something"}}',CODE
HIGH…tests/unit/google/cloud/transfers/test_mssql_to_gcs.py298 assert schema.field("some_binary").type.equals(pyarrow.bool_())CODE
HIGH…tests/unit/google/cloud/transfers/test_mssql_to_gcs.py299 assert schema.field("some_bit").type.equals(pyarrow.bool_())CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py398 assert df.equals(OUTPUT_DF)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py420 assert df.equals(OUTPUT_DF)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py442 assert df.equals(OUTPUT_DF)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py472 assert df.equals(output_df)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py501 assert df.equals(OUTPUT_DF_WITH_EXCLUDE_COLUMNS)CODE
HIGH…e/tests/unit/google/cloud/transfers/test_sql_to_gcs.py529 assert concat_df.equals(OUTPUT_DF)CODE
HIGH…system/google/cloud/cloud_build/example_cloud_build.py69 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}],CODE
HIGH…system/google/cloud/cloud_build/example_cloud_build.py76 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 200"]}],CODE
HIGH…system/google/cloud/cloud_build/example_cloud_build.py82 "steps": [{"name": "ubuntu", "entrypoint": "bash", "args": ["-c", "echo Hello world && sleep 300"]}],CODE
HIGH…oogle/tests/system/google/cloud/ray/example_ray_job.py93 entrypoint="echo hi && sleep 105 && echo hi2",CODE
HIGH…s/google/src/airflow/providers/google/ads/hooks/ads.py57 "json_key_file_path": null,STRING
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py68 If set to None (null), requests for connections will not be sent to GCP Secrets ManagerSTRING
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py70 If set to None (null), requests for variables will not be sent to GCP Secrets ManagerSTRING
HIGH…rflow/providers/google/cloud/secrets/secret_manager.py73 If set to None (null), requests for configurations will not be sent to GCP Secrets ManagerSTRING
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py72 If set to None (null), requests for connections will not be sent to Azure Key VaultSTRING
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py74 If set to None (null), requests for variables will not be sent to Azure Key VaultSTRING
HIGH…airflow/providers/microsoft/azure/secrets/key_vault.py76 If set to None (null), requests for configurations will not be sent to Azure Key VaultSTRING
HIGH…s/standard/tests/unit/standard/decorators/test_bash.py149 assert bash_task.operator.bash_command == "echo hello world && echo 2"CODE
HIGH…s/standard/tests/unit/standard/decorators/test_bash.py152 self.validate_bash_command_rtif(ti, "echo hello world && echo 2")CODE
HIGH…mon/ai/src/airflow/providers/common/ai/sandbox/base.py214 f"sz=$(stat -Lc %s -- {quoted} 2>/dev/null) || exit {self._MISSING_PATH_STATUS}; "CODE
HIGH…/sql/src/airflow/providers/common/sql/operators/sql.py1606 self.push(meta_data)CODE
HIGHproviders/ssh/tests/unit/ssh/utils/test_remote_job.py387 subprocess.run(["bash", "-c", f"kill -9 -{pgid} 2>/dev/null || true"], check=False)CODE
73 more matches not shown…
AI Structural Patterns714 hits · 665 pts
SeverityFileLineSnippetContext
LOW…ests/tests/airflow_e2e_tests/e2e_test_utils/clients.py216CODE
LOWairflow-ctl/src/airflowctl/api/operations.py525CODE
LOWairflow-ctl/src/airflowctl/api/operations.py596CODE
LOWairflow-ctl/src/airflowctl/ctl/cli_config.py127CODE
LOWtask-sdk/tests/conftest.py230CODE
LOWtask-sdk/tests/conftest.py250CODE
LOWtask-sdk/tests/conftest.py273CODE
LOWtask-sdk/tests/conftest.py318CODE
LOW…s/task_sdk/coordinators/executable/test_coordinator.py67CODE
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py4070CODE
LOW…dk/tests/task_sdk/execution_time/test_email_backend.py30CODE
LOWtask-sdk/dev/datamodel_code_formatter.py144CODE
LOWtask-sdk/src/airflow/sdk/io/path.py61CODE
LOWtask-sdk/src/airflow/sdk/bases/sensor.py115CODE
LOWtask-sdk/src/airflow/sdk/bases/decorator.py441CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py277CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py1029CODE
LOWtask-sdk/src/airflow/sdk/api/client.py858CODE
LOWtask-sdk/src/airflow/sdk/definitions/dag.py1620CODE
LOWtask-sdk/src/airflow/sdk/definitions/connection.py130CODE
LOW…k/src/airflow/sdk/definitions/decorators/task_group.py194CODE
LOW…src/airflow/providers/papermill/operators/papermill.py75CODE
LOW…ocker/src/airflow/providers/docker/operators/docker.py227CODE
LOW…src/airflow/providers/docker/operators/docker_swarm.py133CODE
LOW…src/airflow/providers/discord/hooks/discord_webhook.py186CODE
LOW…src/airflow/providers/discord/hooks/discord_webhook.py287CODE
LOW…eau/src/airflow/providers/tableau/operators/tableau.py99CODE
LOW…amazon/src/airflow/providers/amazon/aws/sensors/sqs.py95CODE
LOW…amazon/src/airflow/providers/amazon/aws/sensors/sqs.py183CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/rds.py187CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/dms.py180CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/dms.py902CODE
LOW…iders/amazon/aws/operators/sagemaker_unified_studio.py115CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/ses.py82CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py126CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py306CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py559CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py769CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/emr.py1312CODE
LOW…low/providers/amazon/aws/operators/redshift_cluster.py160CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/eks.py84CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/eks.py276CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/eks.py528CODE
LOW…on/src/airflow/providers/amazon/aws/operators/batch.py149CODE
LOW…ow/providers/amazon/aws/operators/neptune_analytics.py101CODE
LOW…ow/providers/amazon/aws/operators/neptune_analytics.py604CODE
LOW…ow/providers/amazon/aws/operators/neptune_analytics.py839CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/mwaa.py89CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/glue.py185CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/glue.py682CODE
LOW…zon/src/airflow/providers/amazon/aws/operators/glue.py844CODE
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py281CODE
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py788CODE
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py1224CODE
LOW…zon/aws/operators/sagemaker_unified_studio_notebook.py108CODE
LOW…src/airflow/providers/amazon/aws/operators/datasync.py147CODE
LOW…n/src/airflow/providers/amazon/aws/operators/athena.py91CODE
LOW…mazon/src/airflow/providers/amazon/aws/operators/s3.py827CODE
LOW…irflow/providers/amazon/aws/operators/redshift_data.py135CODE
LOW…flow/providers/amazon/aws/operators/lambda_function.py77CODE
654 more matches not shown…
Modern Structural Boilerplate437 hits · 437 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/src/airflowctl/api/client.py84__all__ = [CODE
LOWairflow-ctl-tests/tests/airflowctl_tests/__init__.py24__all__ = ["console"]CODE
LOWtask-sdk/src/airflow/sdk/__init__.py21__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/types.py28__all__ = ["TaskInstance", "TaskInstanceKey"]CODE
LOWtask-sdk/src/airflow/sdk/timezone.py41__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/listener.py45__all__ = ["get_listener_manager", "ListenerManager"]CODE
LOW…dk/src/airflow/sdk/coordinators/executable/__init__.py23__all__ = ["ExecutableCoordinator", "__version__"]CODE
LOWtask-sdk/src/airflow/sdk/coordinators/java/__init__.py27__all__ = ["JavaCoordinator"]CODE
LOWtask-sdk/src/airflow/sdk/coordinators/node/__init__.py28__all__ = ["NodeCoordinator"]CODE
LOWtask-sdk/src/airflow/sdk/io/__init__.py25__all__ = ["ObjectStoragePath", "attach", "get_fs", "has_fs", "Properties"]CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py106__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py1433 def _set_xcomargs_dependencies(self) -> None:CODE
LOWtask-sdk/src/airflow/sdk/bases/operator.py1441 def _set_xcomargs_dependency(self, field: str, newvalue: Any) -> None:CODE
LOWtask-sdk/src/airflow/sdk/observability/__init__.py21__all__ = ["trace"]CODE
LOWtask-sdk/src/airflow/sdk/observability/stats.py33__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/execution_time/coordinator.py64__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py178__all__ = ["ActivitySubprocess", "WatchedSubprocess", "supervise", "supervise_task"]CODE
LOW…/src/airflow/sdk/execution_time/callback_supervisor.py73__all__ = ["CallbackSubprocess", "supervise_callback"]CODE
LOW…rflow/sdk/execution_time/connection_test_supervisor.py35__all__ = ["supervise_connection_test"]CODE
LOWtask-sdk/src/airflow/sdk/execution_time/context.py400def _set_variable(key: str, value: Any, description: str | None = None, serialize_json: bool = False) -> None:CODE
LOW…sdk/src/airflow/sdk/execution_time/secrets/__init__.py24__all__ = ["ExecutionAPISecretsBackend", "DEFAULT_SECRETS_SEARCH_PATH_WORKERS"]CODE
LOW…-sdk/src/airflow/sdk/execution_time/schema/__init__.py133__all__ = [CODE
LOW…-sdk/src/airflow/sdk/execution_time/schema/migrator.py220__all__ = ["SchemaVersionMigrator", "get_schema_version_migrator"]CODE
LOW…-sdk/src/airflow/sdk/execution_time/sentry/__init__.py23__all__ = ["Sentry"]CODE
LOWtask-sdk/src/airflow/sdk/api/client.py183__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/dag.py89__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/param.py35logger = logging.getLogger(__name__)CODE
LOWtask-sdk/src/airflow/sdk/definitions/retry_policy.py39__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/deadline.py35logger = logging.getLogger(__name__)CODE
LOW…rc/airflow/sdk/definitions/_internal/contextmanager.py33__all__ = ["DagContext", "TaskGroupContext"]CODE
LOWtask-sdk/src/airflow/sdk/definitions/_internal/types.py29__all__ = [CODE
LOWtask-sdk/src/airflow/sdk/definitions/asset/metadata.py29__all__ = ["Metadata"]CODE
LOWtask-sdk/src/airflow/sdk/definitions/asset/__init__.py49__all__ = [CODE
LOW…sdk/src/airflow/sdk/definitions/decorators/__init__.py35__all__ = [CODE
LOW…dk/src/airflow/sdk/definitions/decorators/condition.py36__all__ = ["run_if", "skip_if"]CODE
LOW…rs/neo4j/src/airflow/providers/neo4j/version_compat.py37__all__ = [CODE
LOWproviders/neo4j/src/airflow/providers/neo4j/__init__.py30__all__ = ["__version__"]CODE
LOW…/cohere/src/airflow/providers/cohere/version_compat.py33__all__ = [CODE
LOW…viders/cohere/src/airflow/providers/cohere/__init__.py30__all__ = ["__version__"]CODE
LOW…rs/cohere/src/airflow/providers/cohere/hooks/cohere.py35logger = logging.getLogger(__name__)CODE
LOW…viders/ftp/src/airflow/providers/ftp/version_compat.py38__all__ = ["AIRFLOW_V_3_0_PLUS", "AIRFLOW_V_3_1_PLUS"]CODE
LOWproviders/ftp/src/airflow/providers/ftp/__init__.py30__all__ = ["__version__"]CODE
LOWproviders/ftp/src/airflow/providers/ftp/hooks/ftp.py28logger = logging.getLogger(__name__)CODE
LOW…/presto/src/airflow/providers/presto/version_compat.py37__all__ = [CODE
LOW…viders/presto/src/airflow/providers/presto/__init__.py30__all__ = ["__version__"]CODE
LOW…mill/src/airflow/providers/papermill/version_compat.py33__all__ = [CODE
LOW…/papermill/src/airflow/providers/papermill/__init__.py30__all__ = ["__version__"]CODE
LOW…/docker/src/airflow/providers/docker/version_compat.py48__all__ = [CODE
LOW…viders/docker/src/airflow/providers/docker/__init__.py30__all__ = ["__version__"]CODE
LOW…ders/imap/src/airflow/providers/imap/version_compat.py38__all__ = [CODE
LOWproviders/imap/src/airflow/providers/imap/__init__.py30__all__ = ["__version__"]CODE
LOW…iscord/src/airflow/providers/discord/version_compat.py39__all__ = [CODE
LOW…ders/discord/src/airflow/providers/discord/__init__.py30__all__ = ["__version__"]CODE
LOW…ableau/src/airflow/providers/tableau/version_compat.py38__all__ = ["AIRFLOW_V_3_0_PLUS", "AIRFLOW_V_3_1_PLUS"]CODE
LOW…ders/tableau/src/airflow/providers/tableau/__init__.py30__all__ = ["__version__"]CODE
LOW…rs/amazon/tests/system/amazon/aws/example_sagemaker.py71logger = logging.getLogger(__name__)CODE
LOW…/amazon/src/airflow/providers/amazon/version_compat.py57__all__ = [CODE
LOW…viders/amazon/src/airflow/providers/amazon/__init__.py30__all__ = ["__version__"]CODE
LOW…amazon/src/airflow/providers/amazon/aws/sensors/rds.py200__all__ = [CODE
LOW…azon/src/airflow/providers/amazon/aws/operators/rds.py980__all__ = [CODE
377 more matches not shown…
Redundant / Tautological Comments219 hits · 323 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py129 # Check if directory existsCOMMENT
LOWairflow-ctl/src/airflowctl/ctl/commands/auth_command.py201 # Display resultsCOMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py2192 # Assign task to DagCOMMENT
LOWtask-sdk/dev/datamodel_code_formatter.py102 # Check if the target is 'tasks'COMMENT
LOWtask-sdk/src/airflow/sdk/bases/decorator.py223 # Check if args conflict with names in kwargs.COMMENT
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py1185 # Check if the subprocess has exitedCOMMENT
LOWtask-sdk/src/airflow/sdk/definitions/taskgroup.py386 # Check if the current TaskGroup is emptyCOMMENT
LOW…/airflow/sdk/definitions/_internal/abstractoperator.py242 # Check if the operator has an explicit native rendering preferenceCOMMENT
LOWtask-sdk/src/airflow/sdk/serde/typing.py32 # Check if it is not a dataclass to prevent detecting pydantic dataclasses as pydantic modelsCOMMENT
LOW…ers/amazon/tests/unit/amazon/aws/operators/test_eks.py1260 # Set status to None so define_container_state returns UNDEFINED (not terminal)COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py90 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py163 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py221 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_s3_to_sftp.py279 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py114 # Check if object was created in s3COMMENT
LOW…zon/tests/unit/amazon/aws/transfers/test_sftp_to_s3.py205 # Check if object was created in s3COMMENT
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py172 # Check if a file existsSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py181 # Check if both files existSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py190 # Check if a file existsSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py200 # Check if both files existSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py210 # Check if a file exists and match a certain pattern defined in check_fnSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py221 # Check if a file exists and match a certain regular expression patternSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py232 # Check if a file exists and match a certain pattern defined in check_fnSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_s3.py242 # Check if a file exists and match a certain regular expression patternSTRING
LOWproviders/amazon/tests/system/amazon/aws/example_emr.py92 # Set KeepJobFlowAliveWhenNoSteps to False to avoid the cluster from being torn down prematurely.COMMENT
LOW…amazon/src/airflow/providers/amazon/aws/sensors/ssm.py118 # Check if we should tolerate this failureCOMMENT
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py347 # Set wait_for_completion to False so that it waits for the status in the deferred task.COMMENT
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py881 # Set wait_for_completion to False so that it waits for the status in the deferred task.COMMENT
LOW…rc/airflow/providers/amazon/aws/operators/sagemaker.py1288 # Set wait_for_completion to False so that it waits for the status in the deferred task.COMMENT
LOW…rflow/providers/amazon/aws/transfers/glacier_to_gcs.py99 # Read the file content in chunks using StreamingBodyCOMMENT
LOW…low/providers/amazon/aws/executors/ecs/ecs_executor.py120 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the globalCOMMENT
LOW…providers/amazon/aws/executors/batch/batch_executor.py110 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the globalCOMMENT
LOW…ers/amazon/aws/executors/aws_lambda/lambda_executor.py89 # Check if self has the ExecutorConf set on the self.conf attribute, and if not, set it to the globalCOMMENT
LOW…zon/src/airflow/providers/amazon/aws/hooks/base_aws.py581 # Check if we can find an executorCOMMENT
LOW…ers/teradata/tests/unit/teradata/operators/test_tpt.py292 # Set hook to NoneCOMMENT
LOW…ers/teradata/tests/unit/teradata/operators/test_tpt.py708 # Set hooks to NoneCOMMENT
LOW…rs/teradata/tests/unit/teradata/utils/test_tpt_util.py554 # Check if permissions were set correctlyCOMMENT
LOW…adata/src/airflow/providers/teradata/operators/bteq.py44 # Check if the parameter contains Jinja templating syntaxCOMMENT
LOW…data/src/airflow/providers/teradata/utils/bteq_util.py50 # Check if zsh exists firstCOMMENT
LOW…adata/src/airflow/providers/teradata/utils/tpt_util.py78 # Check if shred is availableCOMMENT
LOW…adata/src/airflow/providers/teradata/utils/tpt_util.py111 # Check if shred is available on remote system (UNIX/Linux)COMMENT
LOW…dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py62 # Check if ``account_id`` was not included in the function signature or, if it is, the value is notCOMMENT
LOW…dbt/cloud/src/airflow/providers/dbt/cloud/hooks/dbt.py872 # Check if the job-run duration has exceeded the ``timeout`` configured.COMMENT
LOW…irflow/providers/edge3/plugins/edge_executor_plugin.py56# Check if EdgeExecutor is actually loadedCOMMENT
LOW…src/airflow/providers/edge3/executors/edge_executor.py63 # Check if self has the ExecutorConf set on the self.conf attribute with all required methods.COMMENT
LOW…src/airflow/providers/edge3/executors/edge_executor.py139 # Check if job already exists with same dag_id, task_id, run_id, map_index, try_numberCOMMENT
LOW…e3/src/airflow/providers/edge3/worker_api/routes/ui.py290 # Check if worker exists firstCOMMENT
LOW…/providers/google/common/utils/id_token_credentials.py151 # Check if application default credentials exist.COMMENT
LOW…viders/google/cloud/sensors/vertex_ai/feature_store.py85 # Check if the sync has completed by verifying end_time existsCOMMENT
LOW…c/airflow/providers/google/cloud/operators/dataproc.py983 # Check if cluster is not in ERROR state.COMMENT
LOW…airflow/providers/google/cloud/transfers/gcs_to_gcs.py299 # Check if prefix contains wildcardCOMMENT
LOW…e/src/airflow/providers/google/cloud/hooks/bigquery.py317 # Check if tableReference is present and is validCOMMENT
LOW…e/src/airflow/providers/google/cloud/hooks/bigquery.py324 # Check if value is already present if no use the provided oneCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py507 # Verify if the output table id from the parse result matches the BQ job output tableCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py516 # Verify if all columns from parse results are present in the output dataset schemaCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py525 # Verify if all datasets from parse results are present in bq job input datasetsCOMMENT
LOW…c/airflow/providers/google/cloud/openlineage/mixins.py529 # Verify if all columns from parse results are present in their respective bq job input datasetsCOMMENT
LOW…rc/airflow/providers/google/cloud/openlineage/utils.py133 # Check if the `InputField` class supports the `transformations` attribute (since OL client 1.17.1)COMMENT
LOW…ogle/src/airflow/providers/google/suite/hooks/drive.py112 # Check if there are directories to processCOMMENT
LOW…src/airflow/providers/cncf/kubernetes/operators/pod.py986 # Check if invoke_defer_method accepts context parameterCOMMENT
159 more matches not shown…
Fake / Example Data278 hits · 286 pts
SeverityFileLineSnippetContext
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py3616 secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore eCODE
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py3616 secret2 = "Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore eCODE
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py237 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"CODE
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py252 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"CODE
LOWproviders/neo4j/tests/unit/neo4j/sensors/test_neo4j.py268 cypher = "MATCH (n:Person{id:'John Doe'}) RETURN n.first_name AS first_name, n.last_name AS last_name"CODE
LOWproviders/docker/provider.yaml148 extra: '{"reauth": false, "email": "Jane.Doe@example.org"}'CODE
LOW…cker/src/airflow/providers/docker/get_provider_info.py69 "placeholders": {"extra": '{"reauth": false, "email": "Jane.Doe@example.org"}'},CODE
LOW…rs/docker/src/airflow/providers/docker/hooks/docker.py229 "email": "Jane.Doe@example.org",CODE
LOW…/tests/unit/amazon/aws/auth_manager/avp/test_facade.py92 "dummy_id",CODE
LOW…/tests/unit/amazon/aws/auth_manager/avp/test_facade.py131 "dummy_id",CODE
LOW…/teradata/tests/system/teradata/example_remote_bteq.py87 INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT');CODE
LOWproviders/teradata/tests/system/teradata/script.sql26INSERT INTO {{params.TABLE_NAME}} VALUES (1, 'John Doe', 'IT');CODE
LOW…oviders/teradata/tests/system/teradata/example_bteq.py87 INSERT INTO {{params.DB_TABLE_NAME}} VALUES (1, 'John Doe', 'IT');CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py45 "from": {"email": "foo@bar.com"},CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py58 "email": "foo@bar.com",CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py68 @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com")CODE
LOW…ers/sendgrid/tests/unit/sendgrid/utils/test_emailer.py100 @mock.patch.dict("os.environ", SENDGRID_MAIL_FROM="foo@bar.com", SENDGRID_MAIL_SENDER="Foo")CODE
LOW…/edge3/tests/unit/edge3/worker_api/routes/test_logs.py62 log_chunk_data="This is Lorem Ipsum log data", log_chunk_time=timezone.utcnow()CODE
LOW…/edge3/tests/unit/edge3/worker_api/routes/test_logs.py81 assert "Lorem Ipsum" in logs[0].log_chunk_dataCODE
LOWproviders/trino/tests/unit/trino/hooks/test_trino.py580 {"login": "user@example.com", "password": "p@ss:word", "host": "localhost", "schema": "hive"},CODE
LOW…ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py73 return_value="test-example@example.org"CODE
LOW…ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py98 user="test-example@example.org",CODE
LOW…ogle/tests/unit/google/cloud/hooks/test_compute_ssh.py145 return_value="test-example@example.org"CODE
LOW…/system/google/cloud/dataflow/example_dataflow_yaml.py83 "('John Doe', 900, 'USA'), "CODE
LOW…ts/unit/cncf/kubernetes/cli/test_kubernetes_command.py309 pods.metadata._continue = "dummy-token"CODE
LOW…ts/unit/cncf/kubernetes/cli/test_kubernetes_command.py324 _continue="dummy-token",CODE
LOW…ers/pgvector/tests/system/pgvector/example_pgvector.py62 f"VALUES ('John Doe', 123, '[1.0, 2.0, 3.0]')",CODE
LOW…ector/tests/system/pgvector/example_pgvector_openai.py75 f"VALUES ('John Doe', '123' ,'{embedd_query.output}')",CODE
LOW…cks/tests/unit/databricks/operators/test_databricks.py176 "name": "John Doe",CODE
LOWproviders/fab/tests/unit/fab/auth_manager/test_utils.py54 email=email or f"{username}@example.org",CODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py33 dummy_token = LoginResponse(access_token="DUMMY_TOKEN")CODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py38 mock_fab_auth_manager_login.create_token.return_value = self.dummy_tokenCODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py46 assert response.json()["access_token"] == self.dummy_token.access_tokenCODE
LOW…unit/fab/auth_manager/api_fastapi/routes/test_login.py59 assert response.json()["access_token"] == self.dummy_token.access_tokenCODE
LOW…it/fab/auth_manager/api_fastapi/services/test_login.py46 self.dummy_token = "DUMMY_TOKEN"CODE
LOW…it/fab/auth_manager/api_fastapi/services/test_login.py50 auth_manager.generate_jwt.return_value = self.dummy_tokenCODE
LOW…it/fab/auth_manager/api_fastapi/services/test_login.py58 assert result.access_token == self.dummy_tokenCODE
LOW…/tests/unit/fab/auth_manager/models/test_user_model.py45 assert user.get_display_name() == "Jane Doe"CODE
LOW…viders/fab/src/airflow/providers/fab/cli/definition.py164 " --email admin@example.org"CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1552 assert token == "dummy_token"CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1567 json=lambda: {"access_token": "dummy_token", "expires_in": 600},CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1530 json=lambda: {"access_token": "dummy_token", "expires_in": 600},CODE
LOW…snowflake/tests/unit/snowflake/hooks/test_snowflake.py1584 assert token == "dummy_token"CODE
LOWproviders/jdbc/tests/unit/jdbc/hooks/test_jdbc.py282 "placeholder": "?",CODE
LOW…mmon/ai/tests/unit/common/ai/operators/test_llm_sql.py787 prompt="placeholder",CODE
LOW…common/ai/tests/unit/common/ai/operators/test_agent.py781 prompt="placeholder",CODE
LOW…s/common/ai/tests/unit/common/ai/operators/test_llm.py417 prompt="placeholder",CODE
LOW…/common/sql/datafusion/test_object_storage_provider.py38 credentials={"access_key_id": "fake_key", "secret_access_key": "fake_secret"},CODE
LOW…/common/sql/datafusion/test_object_storage_provider.py44 access_key_id="fake_key", secret_access_key="fake_secret", bucket_name="demo-data"CODE
LOW…ers/common/sql/tests/unit/common/sql/hooks/test_sql.py254 dbapi_hook = mock_db_hook(DbApiHook, conn_params={"extra": {"placeholder": "?"}})CODE
LOW…ers/common/sql/tests/unit/common/sql/hooks/test_sql.py260 dbapi_hook = mock_db_hook(DbApiHook, conn_params={"extra": {"placeholder": "!"}})CODE
LOW…s/common/sql/tests/unit/common/sql/hooks/test_dbapi.py504 extra=json.dumps({"placeholder": "?"}),CODE
LOW…s/common/sql/tests/unit/common/sql/hooks/test_dbapi.py521 extra=json.dumps({"placeholder": "!"}),CODE
LOW…mmon/sql/src/airflow/providers/common/sql/hooks/sql.py212 placeholder = self.connection_extra.get("placeholder")CODE
LOWproviders/odbc/src/airflow/providers/odbc/hooks/odbc.py153 extra_exclude = {"driver", "dsn", "connect_kwargs", "sqlalchemy_scheme", "placeholder"}CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py72 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py102 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py131 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py189 {"id": "dummy-id", "clientId": "dummy-client"},CODE
LOW…/tests/unit/keycloak/auth_manager/cli/test_commands.py239 {"id": "dummy-id", "clientId": "dummy-client"},CODE
218 more matches not shown…
Overly Generic Function Names224 hits · 161 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/tests/conftest.py65 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py454 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py463 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py472 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py483 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py494 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py503 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py513 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py591 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py600 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py609 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py618 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py627 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py782 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py799 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py875 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py892 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1157 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1166 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1175 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1184 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1193 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1202 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1211 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1220 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1231 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1240 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1249 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1325 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1335 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1676 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1685 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1694 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1703 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1712 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1721 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1946 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1955 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1964 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1973 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1982 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py1991 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py392 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py401 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py415 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py429 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py524 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py567 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py580 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py655 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py671 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py695 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py760 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py771 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py817 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py841 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py854 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py864 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py922 def handle_request(request: httpx.Request) -> httpx.Response:CODE
LOWairflow-ctl/tests/airflow_ctl/api/test_operations.py941 def handle_request(request: httpx.Request) -> httpx.Response:CODE
164 more matches not shown…
Verbosity Indicators80 hits · 118 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py681 # Step 1: Simulate CLI args being parsed (logical_date=None)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py706 # Step 3: Create the Pydantic model (what happens in the actual code)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py709 # Step 4: Verify logical_date was set to nowCOMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py695 # Step 2: Apply the defaulting logic (from cli_config.py lines 622-630)COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py675 # Step 1: create the dag run span and capture its carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py682 # Step 2: derive the parent task span carrier (child of dag run), as the scheduler does.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py692 # Step 3: build StartupDetails with ti.context_carrier = ti_carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py711 # Step 4: emit the worker span (task runner side).COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py717 # Step 5: emit the parent task span (API server side, as happens on task completion).COMMENT
LOWtask-sdk/src/airflow/sdk/bases/decorator.py133 # We need to check if we are in the context of TaskGroup as the task_id mayCOMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py91 # Step 1: Create with machine type A.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py102 # Step 2: Re-run with different machine type and recreate recreate_if_machine_type_different=True.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py114 # Step 3: Validate new machine type.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py120 # Step 4: Cleanup.COMMENT
LOW…iders/cncf/kubernetes/executors/kubernetes_executor.py961 # therefore, we need to check if the TIs are already adopted by the first attempt and remove them.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py164 # Step 1: Decompose the high-level question into sub-questions,COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py193 # Step 2: Generate SQL for each sub-question in parallel.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py207 # Step 3: Wrap each SQL string into a single-element list.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py218 # Step 4: Execute each SQL against the survey CSV via DataFusion.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py229 # Step 5: Collect all four JSON results and label them by dimension.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py248 # Step 6: Synthesize the four labeled result sets into a narrative.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py267 # Step 7: Human reviews the synthesized narrative before the DAG ends.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py408 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py443 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py473 # Step 3: Map sub-questions to retrieval kwargs.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py490 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py526 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py541 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py567 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py599 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py420 # Step 1: Build the AIP list from the registry, using Confluence pageCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py454 # Step 2: Fetch the repo file tree from GitHub once, shared acrossCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py491 # Step 3: Gather evidence from Confluence, GitHub, and the file tree.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py601 # Step 4: Format the gathered evidence into an LLM analysis prompt.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py627 # Step 5: Analyze each AIP with a structured LLM call.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py643 # Step 6: Collect all per-AIP analyses into a combined context.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py660 # Step 7: Format the structured analyses as readable markdown.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py711 # Step 8: Synthesize a cross-AIP progress report.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py737 # Step 9: AI-powered hallucination validation.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py769 # Step 10: Apply validation corrections deterministically.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py849 # Step 11: Build the review body for the human reviewer, showingCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py888 # Step 12: A maintainer reviews the corrected report. The DAGCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py365 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py400 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py430 # Step 3: Map sub-questions to LlamaIndexRetrievalOperator kwargs.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py446 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py460 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py478 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py504 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py536 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py317 # Step 4: SQL generation -- LLM translates the fixed question.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py329 # Step 5: SQL execution via Apache DataFusion.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py339 # Step 6: Extract data rows from the JSON result.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py351 # Step 7: Send result via email if SMTP is configured, otherwise log.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py175 # Step 1: Prompt confirmation -- review or edit the question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py191 # Step 2: SQL generation -- LLM translates the confirmed question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py202 # Step 3: SQL execution via Apache DataFusion.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py212 # Step 4: Extract data rows from the JSON result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py225 # Step 5: Result confirmation -- approve or reject the query result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py271 # Step 1: Download the survey CSV from the Airflow website.STRING
20 more matches not shown…
Structural Annotation Overuse78 hits · 115 pts
SeverityFileLineSnippetContext
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py681 # Step 1: Simulate CLI args being parsed (logical_date=None)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py706 # Step 3: Create the Pydantic model (what happens in the actual code)COMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py709 # Step 4: Verify logical_date was set to nowCOMMENT
LOWairflow-ctl/tests/airflow_ctl/ctl/test_cli_config.py695 # Step 2: Apply the defaulting logic (from cli_config.py lines 622-630)COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py675 # Step 1: create the dag run span and capture its carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py682 # Step 2: derive the parent task span carrier (child of dag run), as the scheduler does.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py692 # Step 3: build StartupDetails with ti.context_carrier = ti_carrier.COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py711 # Step 4: emit the worker span (task runner side).COMMENT
LOW…-sdk/tests/task_sdk/execution_time/test_task_runner.py717 # Step 5: emit the parent task span (API server side, as happens on task completion).COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py91 # Step 1: Create with machine type A.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py102 # Step 2: Re-run with different machine type and recreate recreate_if_machine_type_different=True.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py114 # Step 3: Validate new machine type.COMMENT
LOW…google/cloud/compute/example_compute_recreate_drift.py120 # Step 4: Cleanup.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py164 # Step 1: Decompose the high-level question into sub-questions,COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py193 # Step 2: Generate SQL for each sub-question in parallel.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py207 # Step 3: Wrap each SQL string into a single-element list.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py218 # Step 4: Execute each SQL against the survey CSV via DataFusion.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py229 # Step 5: Collect all four JSON results and label them by dimension.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py248 # Step 6: Synthesize the four labeled result sets into a narrative.COMMENT
LOW…s/common/ai/example_dags/example_llm_survey_agentic.py267 # Step 7: Human reviews the synthesized narrative before the DAG ends.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py408 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py443 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py473 # Step 3: Map sub-questions to retrieval kwargs.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py490 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py526 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py541 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py567 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…viders/common/ai/example_dags/example_langchain_10k.py599 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py420 # Step 1: Build the AIP list from the registry, using Confluence pageCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py454 # Step 2: Fetch the repo file tree from GitHub once, shared acrossCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py491 # Step 3: Gather evidence from Confluence, GitHub, and the file tree.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py601 # Step 4: Format the gathered evidence into an LLM analysis prompt.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py627 # Step 5: Analyze each AIP with a structured LLM call.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py643 # Step 6: Collect all per-AIP analyses into a combined context.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py660 # Step 7: Format the structured analyses as readable markdown.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py711 # Step 8: Synthesize a cross-AIP progress report.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py737 # Step 9: AI-powered hallucination validation.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py769 # Step 10: Apply validation corrections deterministically.COMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py849 # Step 11: Build the review body for the human reviewer, showingCOMMENT
LOW…common/ai/example_dags/example_aip_progress_tracker.py888 # Step 12: A maintainer reviews the corrected report. The DAGCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py365 # Step 1: Analyst submits the comparison question via HITL.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py400 # Step 2: LLM decomposes the question into company-specificCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py430 # Step 3: Map sub-questions to LlamaIndexRetrievalOperator kwargs.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py446 # Step 4: Retrieve relevant chunks for each sub-question.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py460 # Step 5: Collect all retrieval results into a single context.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py478 # Step 6: Synthesize a structured comparison report.COMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py504 # Step 7: Format the structured report into readable text for theCOMMENT
LOW…iders/common/ai/example_dags/example_llamaindex_10k.py536 # Step 8: Analyst reviews the report before it reaches theCOMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py317 # Step 4: SQL generation -- LLM translates the fixed question.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py329 # Step 5: SQL execution via Apache DataFusion.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py339 # Step 6: Extract data rows from the JSON result.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py351 # Step 7: Send result via email if SMTP is configured, otherwise log.COMMENT
LOW…/common/ai/example_dags/example_llm_survey_analysis.py175 # Step 1: Prompt confirmation -- review or edit the question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py191 # Step 2: SQL generation -- LLM translates the confirmed question.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py202 # Step 3: SQL execution via Apache DataFusion.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py212 # Step 4: Extract data rows from the JSON result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py225 # Step 5: Result confirmation -- approve or reject the query result.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py271 # Step 1: Download the survey CSV from the Airflow website.STRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py283 # Step 2: Write the downloaded CSV to disk and generate a referenceSTRING
LOW…/common/ai/example_dags/example_llm_survey_analysis.py302 # Step 3: Validate the downloaded CSV schema against the reference.STRING
18 more matches not shown…
AI Slop Vocabulary43 hits · 92 pts
SeverityFileLineSnippetContext
MEDIUMairflow-e2e-tests/docker/openlineage.yml27 # These DAGs are the only ones the harness drives; keep the stock example DAGs out of the way.COMMENT
MEDIUMairflow-e2e-tests/tests/airflow_e2e_tests/conftest.py773 # so it must not also load the stock e2e dags — the harness triggers every dag it finds.COMMENT
MEDIUM…ts/airflow_e2e_tests/openlineage_tests/prepare_dags.py45# The marker after which everything is Airflow's in-process test harness (pytest-only).COMMENT
MEDIUMtask-sdk/tests/task_sdk/bases/test_operator.py83# Essentially similar to airflow.models.baseoperator.BaseOperatorCOMMENT
LOWtask-sdk/src/airflow/sdk/execution_time/comms.py228 # `__class_getitem__`, but that's a lot of code the one subclass we've got currently. So we'll just use aCOMMENT
LOWtask-sdk/src/airflow/sdk/execution_time/supervisor.py2284# and it doesn't contain a new line character, `.readline()` will just return the chunk as is.COMMENT
LOW…rs/amazon/tests/unit/amazon/aws/hooks/test_datasync.py43# mock_get_conn. We then override it to just return the locally created self.client instead ofCOMMENT
LOW…/amazon/src/airflow/providers/amazon/aws/sensors/s3.py182 # Otherwise, just pass the filesCOMMENT
LOW…irflow/providers/amazon/aws/operators/redshift_data.py268 # case, pull each of the sub-statement ID's, and grab the results. Otherwise, just use statement_idCOMMENT
MEDIUM…viders/edge3/src/airflow/providers/edge3/cli/worker.py547 # Technically safer and more robust, but with more overheadCOMMENT
MEDIUM…irflow/providers/google/cloud/utils/field_validator.py350 # Certainly down from here the field is present (value is not None)COMMENT
LOW…w/providers/google/cloud/utils/credentials_provider.py498 # if it's already a dict, just return itCOMMENT
MEDIUM…rc/airflow/providers/google/cloud/hooks/compute_ssh.py42# TODO:(potiuk) We should add test harness detecting such cases shortlyCOMMENT
LOW…e/src/airflow/providers/snowflake/utils/openlineage.py107 # else - its new hostname, just return itCOMMENT
MEDIUM…/ai/src/airflow/providers/common/ai/operators/agent.py106 # Only report "extra not installed" when pydantic-ai-harness itself isCOMMENT
LOW…lineage/tests/unit/openlineage/extractors/test_base.py454 # just return empty OperatorLineageCOMMENT
MEDIUM…ders/openlineage/tests/system/openlineage/constants.py25# Overridable via env var — the e2e harness runs every DAG in the same deployment and wants aCOMMENT
LOW…lineage/src/airflow/providers/openlineage/utils/sql.py203 # Don't iterate over tables hierarchy, just pass it to query single information schema tableCOMMENT
LOW…e/src/airflow/providers/salesforce/hooks/salesforce.py252 # just return the original column untouchedCOMMENT
MEDIUM…openai/src/airflow/providers/openai/triggers/openai.py88 # Measure elapsed time with time.monotonic() so the timeout is robustCOMMENT
MEDIUMchart/values.yaml31# For now this is an opt-in switch for backwards compatibility to leverage the standard naming conventionCOMMENT
MEDIUMchart/values.yaml324# Specify executors in a prioritized list to leverage multiple execution environments as needed:COMMENT
MEDIUMchart/files/statsd-mappings.yml21# instead utilize `statsd.extraMappings` or `statsd.overrideMappings` in your environment,COMMENT
LOW…nfiguration/src/airflow_shared/configuration/parser.py1516 # have these types is with `fallback=` was specified. So just return it.COMMENT
LOW…ared/logging/src/airflow_shared/logging/_noncaching.py36 # we should simply return the wrapper retrieved by FileHandler's open methodCOMMENT
LOWairflow-core/tests/unit/cli/test_hot_reload.py63 # Should just call the callback directlyCOMMENT
LOW…/src/airflow/api_fastapi/execution_api/routes/xcoms.py359# TODO: once we have JWT tokens, then remove dag_id/run_id/task_id from the URL and just use the info inCOMMENT
MEDIUM…c/airflow/config_templates/default_webserver_config.py111# in order to fully utilize the theme. (or use that property in conjunction with theme)COMMENT
MEDIUM…c/airflow/config_templates/default_webserver_config.py111# in order to fully utilize the theme. (or use that property in conjunction with theme)COMMENT
LOWairflow-core/src/airflow/timetables/trigger.py289 # values, so we can just use the first to represent them.COMMENT
MEDIUMairflow-core/src/airflow/triggers/base.py505 """Yield this event in order to end the task successfully."""STRING
MEDIUMairflow-core/src/airflow/triggers/base.py511 """Yield this event in order to end the task with failure."""STRING
MEDIUMairflow-core/src/airflow/triggers/base.py517 """Yield this event in order to end the task with status 'skipped'."""STRING
LOWairflow-core/src/airflow/serialization/encoders.py419 # values, so we can just use the first to represent them.COMMENT
LOWairflow-core/src/airflow/utils/db.py1533 # Older version before we added that function, it only has a single migration so we can just create the tablesCOMMENT
LOWairflow-core/src/airflow/utils/dot_renderer.py241 # (we can just use the maybe-None label variable directly)COMMENT
LOWairflow-core/src/airflow/utils/sqlalchemy.py372 # below is the only line we change, and we just add default=None for getattrCOMMENT
LOW…core/src/airflow/utils/log/non_caching_file_handler.py31 # we should simply return the wrapper retrieved by FileHandler's open methodCOMMENT
LOWairflow-core/src/airflow/cli/commands/db_command.py66 # Exact match found, we can just return itCOMMENT
LOW…flow-core/src/airflow/dag_processing/importers/base.py238 # If it's a file, just return it if we can handle itCOMMENT
MEDIUMdev/breeze/src/airflow_breeze/utils/selective_checks.py1119 # matrix: the shared e2e harness (conftest / constants) or the compat Dockerfile. The compatCOMMENT
LOWdev/breeze/src/airflow_breeze/params/shell_params.py518 # Socket is something different (TCP?) just pass it through as DOCKER_HOST variableCOMMENT
MEDIUM…airflow_breeze/commands/release_management_commands.py2254 """Cleans up the old airflow providers artifacts in order to maintainSTRING
Slop Phrases28 hits · 68 pts
SeverityFileLineSnippetContext
LOWclients/python/test_python_client.py53# auth manager for instance AwsAuthManagerUser or SimpleAuthManager make sure to generate the token withCOMMENT
LOWairflow-ctl/src/airflowctl/api/client.py114 # If you are updating here don't forget to update the airflow-ctl-testsCOMMENT
LOWairflow-ctl/src/airflowctl/api/client.py114 # If you are updating here don't forget to update the airflow-ctl-testsCOMMENT
LOW…mazon/tests/system/amazon/aws/example_mwaa_airflow2.py58 # If creating the environment using the AWS console, make sure to have a VPC withCOMMENT
LOW…oviders/amazon/tests/system/amazon/aws/example_mwaa.py59 # If creating the environment using the AWS console, make sure to have a VPC withCOMMENT
MEDIUM…adata/src/airflow/providers/teradata/hooks/teradata.py84 # Optionally, you can replace the original value in the query_band_textCOMMENT
MEDIUM…stem/google/cloud/dataplex/example_dataplex_catalog.py80 "description": "A simple AspectType for demonstration purposes.",CODE
MEDIUM…ers/pgvector/tests/system/pgvector/example_pgvector.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, taskCOMMENT
MEDIUM…ector/tests/system/pgvector/example_pgvector_openai.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, task, teardownCOMMENT
MEDIUM…ineage/tests/unit/openlineage/plugins/test_listener.py410 # Now you can use listener and task_instance in your tests to simulate their interaction.STRING
MEDIUM…ineage/tests/unit/openlineage/plugins/test_listener.py1285 # Now you can use listener and task_instance in your tests to simulate their interaction.STRING
MEDIUM…airbyte/src/airflow/providers/airbyte/hooks/airbyte.py61 # Intentionally left the password out, you can modify the log to print it out if you are doing testing.COMMENT
MEDIUM…irflow/providers/apache/tinkerpop/operators/gremlin.py46 # If you prefer, you can add an alias run_query = run in your hook.COMMENT
MEDIUMproviders/openai/tests/system/openai/example_openai.py22# If you only need Airflow 3+, you can use: from airflow.sdk import dag, taskCOMMENT
MEDIUMchart/values.yaml490 # or, you can use a different database like:COMMENT
MEDIUMchart/values.yaml590 # This is an example config showing how you can use templating and how "example" configCOMMENT
LOW…art/tests/helm_tests/airflow_aux/test_chart_quality.py36 # we don't forget to update the schema if we add a new propertyCOMMENT
LOW…art/tests/helm_tests/airflow_aux/test_chart_quality.py36 # we don't forget to update the schema if we add a new propertyCOMMENT
MEDIUM…low-core/docs/howto/docker-compose/docker-compose.yaml45# Feel free to modify this file to suit your needs.COMMENT
MEDIUM…low-core/docs/howto/docker-compose/docker-compose.yaml49 # In order to add custom dependencies or upgrade provider distributions you can use your extended image.COMMENT
MEDIUM…c/airflow/config_templates/default_webserver_config.py108# that you can use for Apache Airflow.COMMENT
LOW…c/airflow/config_templates/default_webserver_config.py110# Please make sure to remove "navbar_color" configuration from airflow.cfgCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py63 # Therefore you can add the "section" attribute.COMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py65 # Note if you can add any Markdown formatting to the description, you need to use the description_mdCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py80 # If you want to have a selection list box then you can use the enum feature of JSON schemaCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py192 # then you can use the examples feature of JSON schemaCOMMENT
MEDIUM…src/airflow/example_dags/example_params_ui_tutorial.py312 # then you can use the JSON schema option of passing constant values. These parametersCOMMENT
LOWscripts/ci/prek/check_integrations_list.py201 "[yellow]Regenerating documentation table. Don't forget to review and commit possible changes.[/]"CODE
Modern AI Meta-Vocabulary19 hits · 60 pts
SeverityFileLineSnippetContext
MEDIUMpyproject.toml735# FastAPI dependency injection uses function calls in argument defaults intentionally.COMMENT
MEDIUMpyproject.toml811# Annotated is central for FastAPI dependency injection, skipping rules for FastAPI folders.COMMENT
MEDIUM.apache-magpie-overrides/README.md30[`docs/setup/agentic-overrides.md`](https://github.com/apache/magpie/blob/main/docs/setup/agentic-overrides.md)CODE
MEDIUM…viders/amazon/tests/system/amazon/aws/utils/bedrock.py49 # Haiku has some version dependency issues: RAG only supports 3.5 but batch only supports 4.5COMMENT
MEDIUM…/unit/common/ai/operators/test_llamaindex_retrieval.py101 # The retrieval-time embedding model is passed directly (no Settings mutation).COMMENT
MEDIUM…common/ai/tests/unit/common/ai/hooks/test_langchain.py96 # extra placeholder shows both chat and embedding model keysCOMMENT
MEDIUM…src/airflow/providers/common/ai/utils/query_results.py40# unaffected, small enough that no single tool result can dominate the context window.COMMENT
MEDIUM…common/ai/example_dags/example_langchain_tool_agent.py217 # re-initialising the embedding model on every call would be wasteful.COMMENT
MEDIUM…s/common/ai/example_dags/example_agent_capabilities.py127# 4. Input guardrails: reject unsafe input before the agent run startsCOMMENT
MEDIUM…iders/common/ai/example_dags/example_llamaindex_rag.py41# 1. Full RAG pipeline: load -> embed -> retrieve -> answerCOMMENT
MEDIUM…iders/common/ai/example_dags/example_llamaindex_rag.py192# 3. Multi-source RAG: combine CSV product data with text documentationCOMMENT
MEDIUM…common/ai/example_dags/example_aip_progress_tracker.py737 # Step 9: AI-powered hallucination validation.COMMENT
MEDIUM…irflow/providers/common/ai/example_dags/example_llm.py136 # tokens, or 1_000 output tokens. Useful for guardrails on sharedCOMMENT
MEDIUM.agents/skills/magpie-setup/overrides.md4# overrides — manage agentic overrides for framework skillsCOMMENT
MEDIUM.agents/skills/magpie-setup/overrides.md71## Override file scaffoldCOMMENT
MEDIUM.agents/skills/magpie-setup/adopt.md703[`docs/setup/agentic-overrides.md`](https://github.com/apache/magpie/blob/main/docs/setup/agentic-overrides.md)CODE
MEDIUM…flow-core/src/airflow/api_fastapi/execution_api/app.py406 # Set up dag_bag in app state for dependency injectionCOMMENT
MEDIUMairflow-core/src/airflow/models/trigger.py451 # It prioritizes callbacks, then DAGs over event driven scheduling which is fairCOMMENT
MEDIUM…c/adr/0017-use-uvx-to-run-breeze-from-local-sources.md91# so each worktree (e.g. parallel agentic runs) gets its own ephemerally-installedCOMMENT
Docstring Block Structure12 hits · 60 pts
SeverityFileLineSnippetContext
HIGH…radata/src/airflow/providers/teradata/operators/tpt.py176 Normalize error_list parameter to a list of integers. Args: error_list: An integer, list oSTRING
HIGH…radata/src/airflow/providers/teradata/operators/tpt.py577 Handle execution using a local job variable file. Args: file_path: Path to the local job vSTRING
HIGH…s/teradata/src/airflow/providers/teradata/hooks/tpt.py86 Execute a DDL statement using TPT. Args: tpt_script: TPT script content as string or list STRING
HIGH…s/teradata/src/airflow/providers/teradata/hooks/tpt.py247 Execute a tdload operation using the tdload command-line utility. Args: remote_working_dirSTRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py63 Merge multiple column lineage facets into a single consolidated facet. Specifically, it aggregates input fieldSTRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py163 Extract and process the dataset name from a given path. Args: path: The path to process e.g. of a gcs STRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py276 Get column lineage facet for identity transformations. This function generates a simple column lineage facet, STRING
HIGH…rc/airflow/providers/google/cloud/openlineage/utils.py418 Replace the properties of a specific job type in a Dataproc job definition. Args: job: The original DaSTRING
HIGH…ndard/src/airflow/providers/standard/operators/hitl.py315 Generate a URL link to the "required actions" page for a specific task instance. This URL includes queSTRING
HIGH…e/tests/system/openlineage/expected_events/__init__.py31 Retrieve the file path to the OpenLineage expected events JSON file for a given DAG ID, taking into account theSTRING
HIGH…c/airflow/api_fastapi/core_api/services/ui/calendar.py295 Get database-specific time truncation expression for SQLAlchemy. We want to return always timestamp foSTRING
HIGH…sdk-integration-tests/tests/task_sdk_tests/conftest.py436 Utility to set up a DAG run and create an SDK client. This function handles the common pattern of: 1. GettSTRING
Dead Code21 hits · 42 pts
SeverityFileLineSnippetContext
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py578CODE
MEDIUM…ts/unit/amazon/aws/log/test_cloudwatch_task_handler.py591CODE
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1467CODE
MEDIUM…es/tests/unit/cncf/kubernetes/hooks/test_kubernetes.py1661CODE
MEDIUM…ers/standard/tests/unit/standard/triggers/test_file.py260CODE
MEDIUM…erg/tests/unit/apache/iceberg/triggers/test_iceberg.py87CODE
MEDIUMairflow-core/tests/unit/triggers/test_shared_stream.py192CODE
MEDIUMairflow-core/tests/unit/triggers/test_shared_stream.py2552CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1228CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py622CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py693CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py709CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py735CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py908CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py925CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1266CODE
MEDIUMairflow-core/tests/unit/models/test_mappedoperator.py1313CODE
MEDIUMairflow-core/tests/unit/models/test_dagrun.py3936CODE
MEDIUMairflow-core/src/airflow/triggers/base.py197CODE
MEDIUMairflow-core/src/airflow/triggers/base.py402CODE
MEDIUMairflow-core/src/airflow/triggers/base.py445CODE
Synthetic Comment Markers2 hits · 8 pts
SeverityFileLineSnippetContext
HIGH…rc/airflow/providers/edge3/example_dags/win_notepad.py72 "This is a text as proposal generated by Airflow DAG. Change it and save and it will get to XCom.",CODE
HIGH…cncf/kubernetes/executors/kubernetes_executor_utils.py893 :param kube_config: The KubeConfig class generated by airflow that contains all kube metadataSTRING
Example Usage Blocks5 hits · 8 pts
SeverityFileLineSnippetContext
LOWproviders/informatica/dev/docker-compose.yml20# Usage:COMMENT
LOWjava-sdk/scripts/ci/verify-source-release.sh22# Usage:COMMENT
LOWjava-sdk/scripts/ci/smoke-test-staged-binaries.sh25# Usage:COMMENT
LOWdev/prune_old_dirs.py22# Usage:COMMENT
LOWdev/sync_fork.sh28# Usage:COMMENT
AI Response Leakage1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…src/airflow/example_dags/example_params_ui_tutorial.py152 # In this example we have no default valueCOMMENT